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

[TEST] Expect all shards to fail if full refresh failed

This commit is contained in:
Simon Willnauer 2014-04-01 16:57:27 +02:00
parent 4da66c4f95
commit 257eddd8f0
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/test/java/org/elasticsearch/search/basic/SearchWithRandomExceptionsTests.java
View File

@ -151,7 +151,7 @@ public class SearchWithRandomExceptionsTests extends ElasticsearchIntegrationTes
} }
NumShards test = getNumShards("test"); NumShards test = getNumShards("test");
logger.info("Start Refresh"); logger.info("Start Refresh");
RefreshResponse refreshResponse = client().admin().indices().prepareRefresh("test").execute().get(); // don't assert on failures here final RefreshResponse refreshResponse = client().admin().indices().prepareRefresh("test").execute().get(); // don't assert on failures here
final boolean refreshFailed = refreshResponse.getShardFailures().length != 0 || refreshResponse.getFailedShards() != 0; final boolean refreshFailed = refreshResponse.getShardFailures().length != 0 || refreshResponse.getFailedShards() != 0;
logger.info("Refresh failed [{}] numShardsFailed: [{}], shardFailuresLength: [{}], successfulShards: [{}], totalShards: [{}] ", refreshFailed, refreshResponse.getFailedShards(), refreshResponse.getShardFailures().length, refreshResponse.getSuccessfulShards(), refreshResponse.getTotalShards()); logger.info("Refresh failed [{}] numShardsFailed: [{}], shardFailuresLength: [{}], successfulShards: [{}], totalShards: [{}] ", refreshFailed, refreshResponse.getFailedShards(), refreshResponse.getShardFailures().length, refreshResponse.getSuccessfulShards(), refreshResponse.getTotalShards());
final int numSearches = scaledRandomIntBetween(10, 20); final int numSearches = scaledRandomIntBetween(10, 20);
@ -165,10 +165,10 @@ public class SearchWithRandomExceptionsTests extends ElasticsearchIntegrationTes
// check match all // check match all
searchResponse = client().prepareSearch().setQuery(QueryBuilders.matchAllQuery()).get(); searchResponse = client().prepareSearch().setQuery(QueryBuilders.matchAllQuery()).get();
} catch (SearchPhaseExecutionException ex) { } catch (SearchPhaseExecutionException ex) {
if (!expectAllShardsFailed) { if (expectAllShardsFailed || refreshResponse.getSuccessfulShards() == 0) {
throw ex;
} else {
logger.info("expected SearchPhaseException: [{}]", ex.getMessage()); logger.info("expected SearchPhaseException: [{}]", ex.getMessage());
} else {
throw ex;
} }
} }
} }