This is an automated email from the ASF dual-hosted git repository.

Wei-hao-Li pushed a commit to branch lwh/fix-1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit c44c8188649ccb5ce67348e53ede8fe0838d21bc
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 a629c151fa9..183e51b7e1e 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
@@ -162,6 +162,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
           }

Reply via email to