This is an automated email from the ASF dual-hosted git repository.
JackieTien97 pushed a commit to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/dev/1.3 by this push:
new 310dfd1c282 [To dev/1.3] Fix NPE because of thread of DriverScheduler
was not closed immediately when stop DN
310dfd1c282 is described below
commit 310dfd1c282d3d6e222ef880e0c886ea059a2741
Author: Weihao Li <[email protected]>
AuthorDate: Fri May 8 10:33:54 2026 +0800
[To dev/1.3] Fix NPE because of thread of DriverScheduler was not closed
immediately when stop DN
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
}