This is an automated email from the ASF dual-hosted git repository. Wei-hao-Li pushed a commit to branch fixStopDN in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit cbd90d7490ccc12f36dd845c0d0e58dbc54f9098 Author: Weihao Li <[email protected]> AuthorDate: Fri May 8 09:52:00 2026 +0800 fix Signed-off-by: Weihao Li <[email protected]> --- .../apache/iotdb/db/queryengine/execution/schedule/DriverScheduler.java | 1 + 1 file changed, 1 insertion(+) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/schedule/DriverScheduler.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/schedule/DriverScheduler.java index 047253f7842..16adb9c4d1c 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/schedule/DriverScheduler.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/schedule/DriverScheduler.java @@ -164,6 +164,7 @@ public class DriverScheduler implements IDriverScheduler, IService { t -> { try { t.close(); + t.interrupt(); } catch (IOException e) { // Only a field is set, there's no chance to throw an IOException }
