honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[Test] testRelocationWhileRefreshing should wait for the first shard to be started

This commit is contained in:
Boaz Leskes 2014-06-28 10:40:31 +02:00
parent 9ce66cb167
commit 155620ed8e
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/test/java/org/elasticsearch/recovery/RelocationTests.java
View File

@ -230,7 +230,7 @@ public class RelocationTests extends ElasticsearchIntegrationTest {
logger.info("testRelocationWhileIndexingRandom(numRelocations={}, numberOfReplicas={}, numberOfNodes={})", numberOfRelocations, numberOfReplicas, numberOfNodes); logger.info("testRelocationWhileIndexingRandom(numRelocations={}, numberOfReplicas={}, numberOfNodes={})", numberOfRelocations, numberOfReplicas, numberOfNodes);
String[] nodes = new String[numberOfNodes]; String[] nodes = new String[numberOfNodes];
logger.info("--> starting [node1] ..."); logger.info("--> starting [node_0] ...");
nodes[0] = internalCluster().startNode(); nodes[0] = internalCluster().startNode();
logger.info("--> creating test index ..."); logger.info("--> creating test index ...");
@ -241,8 +241,11 @@ public class RelocationTests extends ElasticsearchIntegrationTest {
.put("index.refresh_interval", -1) // we want to control refreshes c .put("index.refresh_interval", -1) // we want to control refreshes c
).execute().actionGet(); ).execute().actionGet();
// make sure the first shard is started.
ensureYellow();
for (int i = 1; i < numberOfNodes; i++) { for (int i = 1; i < numberOfNodes; i++) {
logger.info("--> starting [node{}] ...", i + 1); logger.info("--> starting [node_{}] ...", i);
nodes[i] = internalCluster().startNode(); nodes[i] = internalCluster().startNode();
if (i != numberOfNodes - 1) { if (i != numberOfNodes - 1) {
ClusterHealthResponse healthResponse = client().admin().cluster().prepareHealth().setWaitForEvents(Priority.LANGUID) ClusterHealthResponse healthResponse = client().admin().cluster().prepareHealth().setWaitForEvents(Priority.LANGUID)