|
@@ -813,6 +813,8 @@ public abstract class ESRestTestCase extends ESTestCase {
|
|
}
|
|
}
|
|
|
|
|
|
private void wipeCluster() throws Exception {
|
|
private void wipeCluster() throws Exception {
|
|
|
|
+ logger.info("Waiting for all cluster updates up to this moment to be processed");
|
|
|
|
+ assertOK(adminClient().performRequest(new Request("GET", "_cluster/health?wait_for_events=languid")));
|
|
|
|
|
|
// Cleanup rollup before deleting indices. A rollup job might have bulks in-flight,
|
|
// Cleanup rollup before deleting indices. A rollup job might have bulks in-flight,
|
|
// so we need to fully shut them down first otherwise a job might stall waiting
|
|
// so we need to fully shut them down first otherwise a job might stall waiting
|