[Test] testIsolateMasterAndVerifyClusterStateConsensus didn't wait on initializing shards before comparing cluster states
This commit is contained in:
parent
f3d90cdb17
commit
e39ac7eef4
|
@ -297,7 +297,7 @@ public class DiscoveryWithNetworkFailuresTests extends ElasticsearchIntegrationT
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
@TestLogging("discovery.zen:TRACE,action:TRACE,cluster.service:TRACE,indices.recovery:TRACE,indices.cluster:TRACE")
|
@TestLogging("discovery.zen:TRACE,action:TRACE,cluster.service:TRACE,indices.recovery:TRACE,indices.cluster:TRACE")
|
||||||
public void voidIsolateMasterAndVerifyClusterStateConsensus() throws Exception {
|
public void testIsolateMasterAndVerifyClusterStateConsensus() throws Exception {
|
||||||
final List<String> nodes = internalCluster().startNodesAsync(3, nodeSettings).get();
|
final List<String> nodes = internalCluster().startNodesAsync(3, nodeSettings).get();
|
||||||
ensureStableCluster(3);
|
ensureStableCluster(3);
|
||||||
|
|
||||||
|
@ -329,9 +329,8 @@ public class DiscoveryWithNetworkFailuresTests extends ElasticsearchIntegrationT
|
||||||
logger.info("issue a reroute");
|
logger.info("issue a reroute");
|
||||||
// trigger a reroute now, instead of waiting for the background reroute of RerouteService
|
// trigger a reroute now, instead of waiting for the background reroute of RerouteService
|
||||||
assertAcked(client().admin().cluster().prepareReroute());
|
assertAcked(client().admin().cluster().prepareReroute());
|
||||||
// and wait for it to finish.
|
// and wait for it to finish and for the cluster to stabilize
|
||||||
assertFalse(client().admin().cluster().prepareHealth().setWaitForRelocatingShards(0).get().isTimedOut());
|
ensureGreen("test");
|
||||||
|
|
||||||
|
|
||||||
// verify all cluster states are the same
|
// verify all cluster states are the same
|
||||||
ClusterState state = null;
|
ClusterState state = null;
|
||||||
|
|
Loading…
Reference in New Issue