add refresh before verifying in the test
This commit is contained in:
parent
9927fd4cdd
commit
8fa8a72175
|
@ -78,6 +78,7 @@ public class ConcurrentIndexingVersioningTest {
|
||||||
|
|
||||||
latch.await();
|
latch.await();
|
||||||
System.out.println("done indexing, verifying docs");
|
System.out.println("done indexing, verifying docs");
|
||||||
|
client.client().admin().indices().prepareRefresh().execute().actionGet();
|
||||||
for (int i = 0; i < NUMBER_OF_DOCS; i++) {
|
for (int i = 0; i < NUMBER_OF_DOCS; i++) {
|
||||||
for (int j = 0; j < 5; j++) {
|
for (int j = 0; j < 5; j++) {
|
||||||
SearchResponse response = client.client().prepareSearch().setQuery(QueryBuilders.termQuery("_id", Integer.toString(i))).execute().actionGet();
|
SearchResponse response = client.client().prepareSearch().setQuery(QueryBuilders.termQuery("_id", Integer.toString(i))).execute().actionGet();
|
||||||
|
|
Loading…
Reference in New Issue