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

wait for green/yellow status

This commit is contained in:
Martijn van Groningen 2013-05-24 17:32:45 +02:00
parent d5ca1be34e
commit 9ed274822d
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/test/java/org/elasticsearch/test/integration/search/query/SimpleQueryTests.java
View File

@ -1079,6 +1079,7 @@ public class SimpleQueryTests extends AbstractNodesTests {
.startObject("num_double").field("type", "double").endObject() .startObject("num_double").field("type", "double").endObject()
.endObject().endObject().endObject()) .endObject().endObject().endObject())
.execute().actionGet(); .execute().actionGet();
client.admin().cluster().prepareHealth("test").setWaitForEvents(Priority.LANGUID).setWaitForYellowStatus().execute().actionGet();
client.prepareIndex("test", "type1", "1").setSource(jsonBuilder().startObject() client.prepareIndex("test", "type1", "1").setSource(jsonBuilder().startObject()
.field("num_byte", 1) .field("num_byte", 1)
@ -1212,6 +1213,7 @@ public class SimpleQueryTests extends AbstractNodesTests {
.startObject("num_double").field("type", "double").endObject() .startObject("num_double").field("type", "double").endObject()
.endObject().endObject().endObject()) .endObject().endObject().endObject())
.execute().actionGet(); .execute().actionGet();
client.admin().cluster().prepareHealth("test").setWaitForEvents(Priority.LANGUID).setWaitForGreenStatus().execute().actionGet();
client.prepareIndex("test", "type1", "1").setSource(jsonBuilder().startObject() client.prepareIndex("test", "type1", "1").setSource(jsonBuilder().startObject()
.field("field1", "test1") .field("field1", "test1")
@ -1274,6 +1276,7 @@ public class SimpleQueryTests extends AbstractNodesTests {
.put("index.number_of_replicas", 0) .put("index.number_of_replicas", 0)
) )
.execute().actionGet(); .execute().actionGet();
client.admin().cluster().prepareHealth("test").setWaitForEvents(Priority.LANGUID).setWaitForGreenStatus().execute().actionGet();
client.prepareIndex("test", "test", "1").setSource(jsonBuilder().startObject() client.prepareIndex("test", "test", "1").setSource(jsonBuilder().startObject()
.field("description", "foo other anything bar") .field("description", "foo other anything bar")
@ -1321,6 +1324,7 @@ public class SimpleQueryTests extends AbstractNodesTests {
.put("index.number_of_replicas", 0) .put("index.number_of_replicas", 0)
) )
.execute().actionGet(); .execute().actionGet();
client.admin().cluster().prepareHealth("test").setWaitForEvents(Priority.LANGUID).setWaitForGreenStatus().execute().actionGet();
client.prepareIndex("test", "test", "1").setSource(jsonBuilder().startObject() client.prepareIndex("test", "test", "1").setSource(jsonBuilder().startObject()
.field("description", "foo other anything bar") .field("description", "foo other anything bar")
@ -1413,6 +1417,7 @@ public class SimpleQueryTests extends AbstractNodesTests {
.execute().actionGet(); .execute().actionGet();
client.admin().cluster().prepareHealth("test").setWaitForEvents(Priority.LANGUID).setWaitForGreenStatus().execute().actionGet();
client.prepareIndex("test", "s", "1").setSource(jsonBuilder().startObject() client.prepareIndex("test", "s", "1").setSource(jsonBuilder().startObject()
.field("online", false) .field("online", false)