ensure no initializing shards before wiping the cluster during setup

Author: slobodanadamovic

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

@@ -368,6 +368,7 @@ protected final void beforeInternal() throws Exception {
         final Scope currentClusterScope = getCurrentClusterScope();
         Callable<Void> setup = () -> {
             cluster().beforeTest(random());
+            ensureNoInitializingShardsBeforeWipingCluster();
             cluster().wipe(excludeTemplates());
             randomIndexTemplate();
             return null;
@@ -386,6 +387,16 @@ protected final void beforeInternal() throws Exception {
 
     }
 
+    protected void ensureNoInitializingShardsBeforeWipingCluster() {
+        logger.info("--> waiting for all initializing shards to complete within a reasonable time before wiping the cluster");
+        assertNoTimeout(
+            client().admin()
+                .cluster()
+                .health(new ClusterHealthRequest(TEST_REQUEST_TIMEOUT, "_all").waitForNoInitializingShards(true))
+                .actionGet()
+        );
+    }
+
     private void printTestMessage(String message) {
         if (isSuiteScopedTest(getClass()) && (getTestName().equals("<unknown>"))) {
             logger.info("[{}]: {} suite", getTestClass().getSimpleName(), message);