We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 818342f commit cfd1592Copy full SHA for cfd1592
x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/plugin/DataNodeComputeHandler.java
@@ -98,6 +98,7 @@ void startComputeOnDataNodes(
98
Runnable runOnTaskFailure,
99
ActionListener<ComputeResponse> outListener
100
) {
101
+ var storedContext = transportService.getThreadPool().getThreadContext().newStoredContext();
102
new DataNodeRequestSender(
103
transportService,
104
esqlExecutor,
@@ -141,7 +142,7 @@ protected void sendRequest(
141
142
final Runnable onGroupFailure;
143
final CancellableTask groupTask;
144
if (configuration.allowPartialResults()) {
- try {
145
+ try (storedContext) {
146
groupTask = computeService.createGroupTask(
147
parentTask,
148
() -> "compute group: data-node [" + node.getName() + "], " + shardIds + " [" + shardIds + "]"
0 commit comments