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 <[email protected]> AuthorDate: Tue Sep 8 00:02:38 2026 +0800 fix Signed-off-by: Weihao Li <[email protected]> --- .../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 {
