Fix ILMDownsampleDisruptionIT.testILMDownsampleRollingRestart (#126692)

Wait for the index to exist on the master node to ensure all nodes have
the latest cluster state.

Fixes #126495

muted-tests.yml

@@ -396,9 +396,6 @@ tests:
 - class: org.elasticsearch.xpack.test.rest.XPackRestIT
   method: test {p0=transform/transforms_start_stop/Test start/stop only starts/stops specified transform}
   issue: https://github.com/elastic/elasticsearch/issues/126466
-- class: org.elasticsearch.xpack.downsample.ILMDownsampleDisruptionIT
-  method: testILMDownsampleRollingRestart
-  issue: https://github.com/elastic/elasticsearch/issues/126495
 - class: org.elasticsearch.smoketest.MlWithSecurityIT
   method: test {yaml=ml/get_trained_model_stats/Test get stats given trained models}
   issue: https://github.com/elastic/elasticsearch/issues/126510

test/framework/src/main/java/org/elasticsearch/test/ESIntegTestCase.java

@@ -1735,17 +1735,21 @@ public abstract class ESIntegTestCase extends ESTestCase {
     }
 
     public static void awaitIndexExists(String index) {
-        awaitIndexExists(index, client());
+        awaitIndexExists(index, client(), SAFE_AWAIT_TIMEOUT);
+    }
+
+    public static void awaitIndexExists(String index, TimeValue timeout) {
+        awaitIndexExists(index, client(), timeout);
     }
 
     public static void awaitIndexExists(String index, Client client) {
+        awaitIndexExists(index, client, SAFE_AWAIT_TIMEOUT);
+    }
+
+    public static void awaitIndexExists(String index, Client client, TimeValue timeout) {
         assertThat("wildcards not supported", index, allOf(not(Metadata.ALL), not(containsString("*"))));
         safeGet(
-            client.admin()
+            client.admin().cluster().prepareHealth(timeout, index).setIndicesOptions(IndicesOptions.LENIENT_EXPAND_OPEN_CLOSED).execute()
-                .cluster()
-                .prepareHealth(SAFE_AWAIT_TIMEOUT, index)
-                .setIndicesOptions(IndicesOptions.LENIENT_EXPAND_OPEN_CLOSED)
-                .execute()
         );
     }
 

x-pack/plugin/downsample/src/internalClusterTest/java/org/elasticsearch/xpack/downsample/ILMDownsampleDisruptionIT.java

@@ -192,8 +192,8 @@ public class ILMDownsampleDisruptionIT extends ESIntegTestCase {
                 throw new AssertionError(e);
             }
         }, 1, TimeUnit.MINUTES);
+        awaitIndexExists(targetIndex, TimeValue.timeValueSeconds(60));
         assertBusy(() -> {
-            assertTrue("target index [" + targetIndex + "] does not exist", indexExists(targetIndex));
             var getSettingsResponse = client().admin()
                 .indices()
                 .getSettings(new GetSettingsRequest(TEST_REQUEST_TIMEOUT).indices(targetIndex))