Skip to content

Commit 71380bd

Browse files
committed
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 fb6cce0 commit 71380bd

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -432,7 +432,7 @@ public void messageReceived(ShardFetchRequest request, TransportChannel channel,
432432
});
433433
TransportActionProxy.registerProxyAction(transportService, FETCH_ID_SCROLL_ACTION_NAME, FetchSearchResult::new);
434434

435-
transportService.registerRequestHandler(FETCH_ID_ACTION_NAME, ShardFetchSearchRequest::new, ThreadPool.Names.SEARCH,
435+
transportService.registerRequestHandler(FETCH_ID_ACTION_NAME, ShardFetchSearchRequest::new, ThreadPool.Names.SEARCH, true, true,
436436
new TaskAwareTransportRequestHandler<ShardFetchSearchRequest>() {
437437
@Override
438438
public void messageReceived(ShardFetchSearchRequest request, TransportChannel channel, Task task) throws Exception {

0 commit comments

Comments
 (0)