Add check for health timeout to shardCleanup test
This commit is contained in:
parent
8ab9d2dd1f
commit
d126558dec
|
@ -78,6 +78,7 @@ public class IndicesStoreTests extends AbstractNodesTests {
|
|||
|
||||
logger.info("--> running cluster_health");
|
||||
ClusterHealthResponse clusterHealth = client1.admin().cluster().health(clusterHealthRequest().setWaitForGreenStatus()).actionGet();
|
||||
assertThat(clusterHealth.isTimedOut(), equalTo(false));
|
||||
logger.info("--> done cluster_health, status " + clusterHealth.getStatus());
|
||||
|
||||
|
||||
|
@ -98,6 +99,7 @@ public class IndicesStoreTests extends AbstractNodesTests {
|
|||
|
||||
logger.info("--> running cluster_health");
|
||||
clusterHealth = client1.admin().cluster().health(clusterHealthRequest().setWaitForGreenStatus().setWaitForNodes("2")).actionGet();
|
||||
assertThat(clusterHealth.isTimedOut(), equalTo(false));
|
||||
logger.info("--> done cluster_health, status " + clusterHealth.getStatus());
|
||||
|
||||
logger.info("--> making sure that shard and it's replica exist on server1, server2 and server3");
|
||||
|
@ -110,6 +112,7 @@ public class IndicesStoreTests extends AbstractNodesTests {
|
|||
|
||||
logger.info("--> running cluster_health");
|
||||
clusterHealth = client("server2").admin().cluster().health(clusterHealthRequest().setWaitForGreenStatus()).actionGet();
|
||||
assertThat(clusterHealth.isTimedOut(), equalTo(false));
|
||||
logger.info("--> done cluster_health, status " + clusterHealth.getStatus());
|
||||
|
||||
logger.info("--> making sure that shard and it's replica are allocated on server1 and server3 but not on server2");
|
||||
|
|
Loading…
Reference in New Issue