Fix DanglingIndicesIT wait conditions (#55105)

Closes #55105
This commit is contained in:
Yannick Welsch 2020-04-14 13:52:53 +02:00
parent 87e8367ece
commit 73c522320a
1 changed files with 3 additions and 3 deletions

View File

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