Use wait_for_active_shards in put follow api call when upgrading fr…

…om 6.7.0 or higher. (#40681) Closes #40677
elastic · Apr 2, 2019 · e9db996 · e9db996
1 parent d26ec27
commit e9db996
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/...g-upgrade-multi-cluster/src/test/java/org/elasticsearch/upgrades/CcrRollingUpgradeIT.java b/...g-upgrade-multi-cluster/src/test/java/org/elasticsearch/upgrades/CcrRollingUpgradeIT.java
@@ -309,7 +309,11 @@ private static void createIndex(RestClient client, String name, Settings setting
     }
 
     private static void followIndex(RestClient client, String leaderCluster, String leaderIndex, String followIndex) throws IOException {
-        final Request request = new Request("PUT", "/" + followIndex + "/_ccr/follow");
+        String endpoint = "/" + followIndex + "/_ccr/follow";
+        if (UPGRADE_FROM_VERSION.onOrAfter(Version.V_6_7_0)) {
+            endpoint += "?wait_for_active_shards=1";
+        }
+        final Request request = new Request("PUT", endpoint);
         request.setJsonEntity("{\"remote_cluster\": \"" + leaderCluster + "\", \"leader_index\": \"" + leaderIndex +
             "\", \"read_poll_timeout\": \"10ms\"}");
         assertOK(client.performRequest(request));