|
@@ -77,7 +77,7 @@ public class DanglingIndicesIT extends ESIntegTestCase {
|
|
|
|
|
|
@Override
|
|
|
public Settings onNodeStopped(String nodeName) throws Exception {
|
|
|
- ensureClusterSizeConsistency();
|
|
|
+ internalCluster().validateClusterFormed();
|
|
|
assertAcked(client().admin().indices().prepareDelete(INDEX_NAME));
|
|
|
return super.onNodeStopped(nodeName);
|
|
|
}
|
|
@@ -108,7 +108,7 @@ public class DanglingIndicesIT extends ESIntegTestCase {
|
|
|
|
|
|
@Override
|
|
|
public Settings onNodeStopped(String nodeName) throws Exception {
|
|
|
- ensureClusterSizeConsistency();
|
|
|
+ internalCluster().validateClusterFormed();
|
|
|
assertAcked(client().admin().indices().prepareDelete(INDEX_NAME));
|
|
|
return super.onNodeStopped(nodeName);
|
|
|
}
|
|
@@ -138,7 +138,7 @@ public class DanglingIndicesIT extends ESIntegTestCase {
|
|
|
|
|
|
@Override
|
|
|
public Settings onNodeStopped(String nodeName) throws Exception {
|
|
|
- ensureClusterSizeConsistency();
|
|
|
+ internalCluster().validateClusterFormed();
|
|
|
assertAcked(client().admin().indices().prepareDelete(INDEX_NAME));
|
|
|
return super.onNodeStopped(nodeName);
|
|
|
}
|