diff --git a/server/src/test/java/org/elasticsearch/cluster/NoMasterNodeIT.java b/server/src/test/java/org/elasticsearch/cluster/NoMasterNodeIT.java index 450aee482d7..1555e9fd4cf 100644 --- a/server/src/test/java/org/elasticsearch/cluster/NoMasterNodeIT.java +++ b/server/src/test/java/org/elasticsearch/cluster/NoMasterNodeIT.java @@ -163,9 +163,7 @@ public class NoMasterNodeIT extends ESIntegTestCase { bulkRequestBuilder.setTimeout(timeout); checkWriteAction(bulkRequestBuilder); - disruptionScheme.stopDisrupting(); - - client().admin().cluster().prepareHealth().setWaitForGreenStatus().setWaitForNodes("3").execute().actionGet(); + internalCluster().clearDisruptionScheme(true); } void checkUpdateAction(boolean autoCreateIndex, TimeValue timeout, ActionRequestBuilder builder) {