honeymoose/OpenSearch
1
0
Fork 0
mirror of https://github.com/honeymoose/OpenSearch.git synced 2025-02-17 10:25:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

Marvel: Check that document count is the same on all data nodes

Browse Source 
closes elastic/elasticsearch#1214

Original commit: elastic/x-pack-elasticsearch@1cf352fa3b
This commit is contained in:
Tanguy Leroux 2016-01-14 17:43:52 +01:00
parent be091b7025
commit a30b894166
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
elasticsearch/x-pack/marvel/src/test/java/org/elasticsearch/marvel/test/MarvelIntegTestCase.java
View File

@ -45,6 +45,7 @@ import java.util.Set;
import java.util.concurrent.TimeUnit;
import static org.elasticsearch.test.hamcrest.ElasticsearchAssertions.assertAcked;
import static org.elasticsearch.test.hamcrest.ElasticsearchAssertions.assertNoFailures;
import static org.hamcrest.Matchers.allOf;
import static org.hamcrest.Matchers.greaterThan;
import static org.hamcrest.Matchers.is;
@ -168,6 +169,7 @@ public abstract class MarvelIntegTestCase extends ESIntegTestCase {
protected void awaitMarvelDocsCount(Matcher<Long> matcher, String... types) throws Exception {
securedFlush();
securedRefresh();
assertBusy(new Runnable() {
@Override
public void run() {
@ -189,8 +191,10 @@ public abstract class MarvelIntegTestCase extends ESIntegTestCase {
}
protected void assertMarvelDocsCount(Matcher<Long> matcher, String... types) {
String indices = MarvelSettings.MARVEL_INDICES_PREFIX + "*";
try {
long count = client().prepareSearch(MarvelSettings.MARVEL_INDICES_PREFIX + "*").setSize(0)
assertNoFailures(client().admin().indices().prepareRefresh(indices).get());
long count = client().prepareSearch(indices).setSize(0)
.setTypes(types).get().getHits().totalHits();
logger.trace("--> searched for [{}] documents, found [{}]", Strings.arrayToCommaDelimitedString(types), count);
assertThat(count, matcher);