[TEST] Also do waitForConcreteMappingsOnAll() call for the .percolator type.

This commit is contained in:
Martijn van Groningen 2014-07-02 22:28:33 +02:00
parent fd19b42cbb
commit 63eaec6f48
1 changed files with 2 additions and 1 deletions

View File

@ -196,6 +196,7 @@ public class RecoveryPercolatorTests extends ElasticsearchIntegrationTest {
logger.info("--> Add dummy docs"); logger.info("--> Add dummy docs");
client().prepareIndex("test", "type1", "1").setSource("field1", 0).get(); client().prepareIndex("test", "type1", "1").setSource("field1", 0).get();
client().prepareIndex("test", "type2", "1").setSource("field1", "0").get(); client().prepareIndex("test", "type2", "1").setSource("field1", "0").get();
waitForConcreteMappingsOnAll("test", "type1", "field1");
logger.info("--> register a queries"); logger.info("--> register a queries");
for (int i = 1; i <= 100; i++) { for (int i = 1; i <= 100; i++) {
@ -208,6 +209,7 @@ public class RecoveryPercolatorTests extends ElasticsearchIntegrationTest {
.endObject()) .endObject())
.get(); .get();
} }
waitForConcreteMappingsOnAll("test", PercolatorService.TYPE_NAME);
logger.info("--> Percolate doc with field1=95"); logger.info("--> Percolate doc with field1=95");
PercolateResponse response = client().preparePercolate() PercolateResponse response = client().preparePercolate()
@ -222,7 +224,6 @@ public class RecoveryPercolatorTests extends ElasticsearchIntegrationTest {
assertAcked(client().admin().indices().prepareClose("test")); assertAcked(client().admin().indices().prepareClose("test"));
assertAcked(client().admin().indices().prepareOpen("test")); assertAcked(client().admin().indices().prepareOpen("test"));
ensureGreen(); ensureGreen();
waitForConcreteMappingsOnAll("test", "type1", "field1");
logger.info("--> Percolate doc with field1=100"); logger.info("--> Percolate doc with field1=100");
response = client().preparePercolate() response = client().preparePercolate()