Skip to content

Commit

Permalink
review fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
diwasjoshi committed Apr 1, 2018
1 parent 2ee128d commit 044d013
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -163,7 +163,7 @@ public class SearchService extends AbstractLifecycleComponent implements IndexEv
private volatile TimeValue defaultSearchTimeout;

private volatile boolean defaultAllowPartialSearchResults;

private volatile boolean lowLevelCancellation;

private final Cancellable keepAliveReaper;
Expand Down Expand Up @@ -233,7 +233,7 @@ private void setDefaultAllowPartialSearchResults(boolean defaultAllowPartialSear
public boolean defaultAllowPartialSearchResults() {
return defaultAllowPartialSearchResults;
}

private void setLowLevelCancellation(Boolean lowLevelCancellation) {
this.lowLevelCancellation = lowLevelCancellation;
}
Expand Down Expand Up @@ -568,7 +568,6 @@ final SearchContext createAndPutContext(ShardSearchRequest request) throws IOExc

final SearchContext createContext(ShardSearchRequest request) throws IOException {
final DefaultSearchContext context = createSearchContext(request, defaultSearchTimeout);
System.out.println("----activecontexts----" + activeContexts.size());
if (activeContexts.size() >= Node.MAX_SEARCH_CONTEXT_SETTING.get(settings)) {
throw new IllegalStateException(
"Trying to create too many search contexts. Must be less than or equal to: [" +
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -447,7 +447,7 @@ public void testCanMatch() throws IOException {
Strings.EMPTY_ARRAY, false, new AliasFilter(null, Strings.EMPTY_ARRAY), 1f, allowPartialSearchResults)));

assertTrue(service.canMatch(new ShardSearchLocalRequest(indexShard.shardId(), 1, SearchType.QUERY_THEN_FETCH,
new SearchSourceBuilder(), Strings.EMPTY_ARRAY, false, new AliasFilter(null, Strings.EMPTY_ARRAY), 1f,
new SearchSourceBuilder(), Strings.EMPTY_ARRAY, false, new AliasFilter(null, Strings.EMPTY_ARRAY), 1f,
allowPartialSearchResults)));

assertTrue(service.canMatch(new ShardSearchLocalRequest(indexShard.shardId(), 1, SearchType.QUERY_THEN_FETCH,
Expand Down

0 comments on commit 044d013

Please sign in to comment.