[ML] Adjust migration full cluster restart tests based on old cluster…

… version elastic#37118
droberts195 · Jan 3, 2019 · fc49d88 · fc49d88
1 parent 13649aa
commit fc49d88
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/...estart/src/test/java/org/elasticsearch/xpack/restart/MlMigrationFullClusterRestartIT.java b/...estart/src/test/java/org/elasticsearch/xpack/restart/MlMigrationFullClusterRestartIT.java
@@ -69,7 +69,6 @@ private void createTestIndex() throws IOException {
         client().performRequest(createTestIndex);
     }
 
-    @AwaitsFix(bugUrl = "https://github.com/elastic/elasticsearch/issues/36816")
     public void testMigration() throws Exception {
         if (isRunningAgainstOldCluster()) {
             createTestIndex();
@@ -157,6 +156,12 @@ private void waitForDatafeedToBeAssigned(String datafeedId) throws Exception {
     @SuppressWarnings("unchecked")
     private void waitForMigration(List<String> expectedMigratedJobs, List<String> expectedMigratedDatafeeds,
                                   List<String> unMigratedJobs, List<String> unMigratedDatafeeds) throws Exception {
+
+        // After v6.6.0 jobs are created in the index so no migration will take place
+        if (getOldClusterVersion().onOrAfter(Version.V_6_6_0)) {
+            return;
+        }
+
         assertBusy(() -> {
             // wait for the eligible configs to be moved from the clusterstate
             Request getClusterState = new Request("GET", "/_cluster/state/metadata");