Skip to content

Commit 44f280f

Browse files
authored
Force execution of fetch tasks (#31974)
Forces fetch tasks to queue even in the event that the queue is already full. The reasoning is that fetch tasks may only be follow-up to query tasks, so the number of additional fetch tasks that may enter the threadpool is expected to be reasonable. Closes #29442
1 parent 043e40a commit 44f280f

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

server/src/main/java/org/elasticsearch/action/search/SearchTransportService.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -409,7 +409,7 @@ public void onFailure(Exception e) {
409409
});
410410
TransportActionProxy.registerProxyAction(transportService, FETCH_ID_SCROLL_ACTION_NAME, FetchSearchResult::new);
411411

412-
transportService.registerRequestHandler(FETCH_ID_ACTION_NAME, ThreadPool.Names.SEARCH, ShardFetchSearchRequest::new,
412+
transportService.registerRequestHandler(FETCH_ID_ACTION_NAME, ThreadPool.Names.SEARCH, true, true, ShardFetchSearchRequest::new,
413413
(request, channel, task) -> {
414414
FetchSearchResult result = searchService.executeFetchPhase(request, (SearchTask)task);
415415
channel.sendResponse(result);

0 commit comments

Comments
 (0)