diff --git a/server/src/main/java/org/elasticsearch/search/DefaultSearchContext.java b/server/src/main/java/org/elasticsearch/search/DefaultSearchContext.java index de174c5e5048..36852b9f5b0e 100644 --- a/server/src/main/java/org/elasticsearch/search/DefaultSearchContext.java +++ b/server/src/main/java/org/elasticsearch/search/DefaultSearchContext.java @@ -157,7 +157,7 @@ final class DefaultSearchContext extends SearchContext { engineSearcher.getQueryCache(), engineSearcher.getQueryCachingPolicy(), lowLevelCancellation, - // use the search threadpool for now, TODO maybe we will change to a separate one + // use the search threadpool for now, TODO this will change to a separate one parallelize ? (EsThreadPoolExecutor) this.indexService.getThreadPool().executor(ThreadPool.Names.SEARCH) : null ); releasables.addAll(List.of(engineSearcher, searcher)); diff --git a/server/src/main/java/org/elasticsearch/search/internal/ContextIndexSearcher.java b/server/src/main/java/org/elasticsearch/search/internal/ContextIndexSearcher.java index 54e2103fd923..c6434efd53a3 100644 --- a/server/src/main/java/org/elasticsearch/search/internal/ContextIndexSearcher.java +++ b/server/src/main/java/org/elasticsearch/search/internal/ContextIndexSearcher.java @@ -117,7 +117,7 @@ private ContextIndexSearcher( boolean wrapWithExitableDirectoryReader, ThreadPoolExecutor executor ) throws IOException { - // we need to pass the executor up so it can porentially be used as a sliceExecutor + // we need to pass the executor up so it can potentially be used as a sliceExecutor super(wrapWithExitableDirectoryReader ? new ExitableDirectoryReader((DirectoryReader) reader, cancellable) : reader, executor); setSimilarity(similarity); setQueryCache(queryCache); @@ -203,7 +203,7 @@ public Weight createWeight(Query query, ScoreMode scoreMode, float boost) throws @Override protected LeafSlice[] slices(List leaves) { - return computeSlices(leaves, queueSizeBasedExecutor.threadPoolExecutor.getPoolSize(), MINIMUM_DOCS_PER_SLICE); + return computeSlices(leaves, ((ThreadPoolExecutor) getExecutor()).getPoolSize(), MINIMUM_DOCS_PER_SLICE); } /**