remove check for failure, might rarely not fail at all
This commit is contained in:
parent
b5ad1c257e
commit
7a082cea4f
|
@ -70,18 +70,12 @@ public class SearchWithRejectionsTests extends ElasticsearchIntegrationTest {
|
||||||
.setSearchType(searchType)
|
.setSearchType(searchType)
|
||||||
.execute();
|
.execute();
|
||||||
}
|
}
|
||||||
int failures = 0;
|
|
||||||
for (int i = 0; i < numSearches; i++) {
|
for (int i = 0; i < numSearches; i++) {
|
||||||
try {
|
try {
|
||||||
SearchResponse searchResponse = responses[i].get();
|
responses[i].get();
|
||||||
if (searchResponse.getFailedShards() > 0) {
|
|
||||||
failures++;
|
|
||||||
}
|
|
||||||
} catch (Throwable t) {
|
} catch (Throwable t) {
|
||||||
failures++;
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
assertThat(failures, greaterThanOrEqualTo(1));
|
|
||||||
awaitBusy(new Predicate<Object>() {
|
awaitBusy(new Predicate<Object>() {
|
||||||
@Override
|
@Override
|
||||||
public boolean apply(Object input) {
|
public boolean apply(Object input) {
|
||||||
|
|
Loading…
Reference in New Issue