[TEST] wait unitl all machines joined the cluster

This commit is contained in:
Simon Willnauer 2014-12-05 18:12:00 +01:00
parent d32f1a8ad0
commit 0bab17ffde
1 changed files with 1 additions and 1 deletions

View File

@ -121,7 +121,7 @@ public class SimpleNodesInfoTests extends ElasticsearchIntegrationTest {
// The fourth has one java plugin and one site plugin // The fourth has one java plugin and one site plugin
String server4NodeId = startNodeWithPlugins(4,TestNoVersionPlugin.class.getName()); String server4NodeId = startNodeWithPlugins(4,TestNoVersionPlugin.class.getName());
ClusterHealthResponse clusterHealth = client().admin().cluster().health(clusterHealthRequest().waitForGreenStatus()).actionGet(); ClusterHealthResponse clusterHealth = client().admin().cluster().health(clusterHealthRequest().waitForNodes("4")).actionGet();
logger.info("--> done cluster_health, status " + clusterHealth.getStatus()); logger.info("--> done cluster_health, status " + clusterHealth.getStatus());
NodesInfoResponse response = client().admin().cluster().prepareNodesInfo().clear().setPlugins(true).execute().actionGet(); NodesInfoResponse response = client().admin().cluster().prepareNodesInfo().clear().setPlugins(true).execute().actionGet();