Test: RelocationTests.testMoveShardsWhileRelocation should wait on nodes to start before asking for a client

The client call may create another node if none of the previous nodes are published. That node throws the test off.
This commit is contained in:
Boaz Leskes 2014-10-20 15:11:15 +02:00
parent 230c6684a9
commit 0146653b92
1 changed files with 3 additions and 3 deletions

View File

@ -337,14 +337,14 @@ public class RelocationTests extends ElasticsearchIntegrationTest {
final String indexName = "test";
ListenableFuture<String> blueFuture = internalCluster().startNodeAsync(ImmutableSettings.builder().put("node.color", "blue").build());
internalCluster().startNodeAsync(ImmutableSettings.builder().put("node.color", "green").build());
ListenableFuture<String> redFuture = internalCluster().startNodeAsync(ImmutableSettings.builder().put("node.color", "red").build());
internalCluster().startNode(ImmutableSettings.builder().put("node.color", "green").build());
final String blueNodeName = blueFuture.get();
final String redNodeName = redFuture.get();
ClusterHealthResponse response = client().admin().cluster().prepareHealth().setWaitForNodes(">=3").get();
assertThat(response.isTimedOut(), is(false));
String blueNodeName = blueFuture.get();
final String redNodeName = redFuture.get();
client().admin().indices().prepareCreate(indexName)
.setSettings(