diff --git a/client/rest-high-level/src/test/java/org/elasticsearch/client/CCRIT.java b/client/rest-high-level/src/test/java/org/elasticsearch/client/CCRIT.java index 2c63835af8c52..b6fa146701d84 100644 --- a/client/rest-high-level/src/test/java/org/elasticsearch/client/CCRIT.java +++ b/client/rest-high-level/src/test/java/org/elasticsearch/client/CCRIT.java @@ -69,7 +69,7 @@ public void setupRemoteClusterConfig() throws Exception { String transportAddress = (String) nodesResponse.get("transport_address"); ClusterUpdateSettingsRequest updateSettingsRequest = new ClusterUpdateSettingsRequest(); - updateSettingsRequest.transientSettings(Collections.singletonMap("cluster.remote.local.seeds", transportAddress)); + updateSettingsRequest.transientSettings(Collections.singletonMap("cluster.remote.local_cluster.seeds", transportAddress)); ClusterUpdateSettingsResponse updateSettingsResponse = highLevelClient().cluster().putSettings(updateSettingsRequest, RequestOptions.DEFAULT); assertThat(updateSettingsResponse.isAcknowledged(), is(true)); @@ -77,7 +77,7 @@ public void setupRemoteClusterConfig() throws Exception { assertBusy(() -> { Map localConnection = (Map) toMap(client() .performRequest(new Request("GET", "/_remote/info"))) - .get("local"); + .get("local_cluster"); assertThat(localConnection, notNullValue()); assertThat(localConnection.get("connected"), is(true)); }); @@ -91,7 +91,7 @@ public void testIndexFollowing() throws Exception { CreateIndexResponse response = highLevelClient().indices().create(createIndexRequest, RequestOptions.DEFAULT); assertThat(response.isAcknowledged(), is(true)); - PutFollowRequest putFollowRequest = new PutFollowRequest("local", "leader", "follower"); + PutFollowRequest putFollowRequest = new PutFollowRequest("local_cluster", "leader", "follower"); PutFollowResponse putFollowResponse = execute(putFollowRequest, ccrClient::putFollow, ccrClient::putFollowAsync); assertThat(putFollowResponse.isFollowIndexCreated(), is(true)); assertThat(putFollowResponse.isFollowIndexShardsAcked(), is(true)); @@ -165,7 +165,7 @@ public void testIndexFollowing() throws Exception { public void testAutoFollowing() throws Exception { CcrClient ccrClient = highLevelClient().ccr(); PutAutoFollowPatternRequest putAutoFollowPatternRequest = - new PutAutoFollowPatternRequest("pattern1", "local", Collections.singletonList("logs-*")); + new PutAutoFollowPatternRequest("pattern1", "local_cluster", Collections.singletonList("logs-*")); putAutoFollowPatternRequest.setFollowIndexNamePattern("copy-{{leader_index}}"); AcknowledgedResponse putAutoFollowPatternResponse = execute(putAutoFollowPatternRequest, ccrClient::putAutoFollowPattern, ccrClient::putAutoFollowPatternAsync);