(iotdb) branch fixDeviceEntry created (now c3691ae3c34)

[we...@apache.org]

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

Wei-hao-Li pushed a change to branch fixDeviceEntry
in repository https://gitbox.apache.org/repos/asf/iotdb.git


      at c3691ae3c34 fix

This branch includes the following new commits:

     new c3691ae3c34 fix

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

(iotdb) 01/01: fix

[we...@apache.org]

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

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

commit c3691ae3c345eeda101ac7b868bc6b703e8f99e4
Author: Weihao Li <18...@163.com>
AuthorDate: Tue Sep 8 00:02:38 2026 +0800

    fix
    
    Signed-off-by: Weihao Li <18...@163.com>
---
 .../plan/relational/metadata/spill/DeviceEntrySpillManager.java     | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/DeviceEntrySpillManager.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/DeviceEntrySpillManager.java
index ebd4218672a..6349d89585b 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/DeviceEntrySpillManager.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/DeviceEntrySpillManager.java
@@ -80,7 +80,11 @@ public final class DeviceEntrySpillManager {
 
   public void deregisterQuery(String queryId) throws IOException {
     queryDirectories.remove(queryId);
-    deleteDirectoryIfExists(resolveQueryDirectory(queryId));
+    Path directory = resolveQueryDirectory(queryId);
+    if (!Files.exists(directory)) {
+      return;
+    }
+    deleteDirectoryIfExists(directory);
   }
 
   public byte[] readSegment(String queryId, String planNodeId, int segmentId) throws IOException {