fix

apache · Feb 19, 2025 · 50f190d · 50f190d
1 parent fe22623
commit 50f190d
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/ResultReceiverConsumer.java b/fe/fe-core/src/main/java/org/apache/doris/qe/ResultReceiverConsumer.java
@@ -112,6 +112,8 @@ public RowBatch getNext(Status status) throws TException, InterruptedException,
             finishedReceivers++;
             if (finishedReceivers != contexts.size()) {
                 rowBatch.setEos(false);
+            } else {
+                executor.shutdownNow();
             }
         } else {
             context.createFuture();