(iotdb) branch master updated: Fix NPE because of thread of DriverScheduler was not closed immediately when stop DN

[jackietien]

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

JackieTien97 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new efeece64216 Fix NPE because of thread of DriverScheduler was not 
closed immediately when stop DN
efeece64216 is described below

commit efeece642160d161c0c8e199c882ea65a7808975
Author: Weihao Li <60659567+wei-hao...@users.noreply.github.com>
AuthorDate: Fri May 8 10:17:53 2026 +0800

    Fix NPE because of thread of DriverScheduler was not closed immediately 
when stop DN
---
 .../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
           }