Skip to content

Commit a8e5929

Browse files
Use EsExecutors.DIRECT_EXECUTOR_SERVICE
1 parent c1e0540 commit a8e5929

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

server/src/main/java/org/elasticsearch/action/admin/indices/resolve/ResolveIndexAction.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -679,7 +679,7 @@ protected void doExecute(Task task, Request request, final ActionListener<Respon
679679
connectionListener.addTimeout(
680680
TimeValue.timeValueSeconds(3L),
681681
transportService.getThreadPool(),
682-
transportService.getThreadPool().executor(ThreadPool.Names.SEARCH_COORDINATION)
682+
EsExecutors.DIRECT_EXECUTOR_SERVICE
683683
);
684684
}
685685

@@ -698,7 +698,7 @@ protected void doExecute(Task task, Request request, final ActionListener<Respon
698698
l.onFailure(failure);
699699
}).map(resolveIndexResponse -> Map.entry(clusterAlias, resolveIndexResponse)),
700700
Response::new,
701-
transportService.getThreadPool().executor(ThreadPool.Names.SEARCH_COORDINATION)
701+
EsExecutors.DIRECT_EXECUTOR_SERVICE
702702
)
703703
)
704704
));

0 commit comments

Comments
 (0)