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 bf072eae22a5b3651fc196f18ab11c3deac50f4e Author: Weihao Li <[email protected]> AuthorDate: Tue Sep 8 09:36:12 2026 +0800 Revert "fix" This reverts commit c3691ae3c345eeda101ac7b868bc6b703e8f99e4. --- .../plan/relational/metadata/spill/DeviceEntrySpillManager.java | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) 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 6349d89585b..ebd4218672a 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,11 +80,7 @@ public final class DeviceEntrySpillManager { public void deregisterQuery(String queryId) throws IOException { queryDirectories.remove(queryId); - Path directory = resolveQueryDirectory(queryId); - if (!Files.exists(directory)) { - return; - } - deleteDirectoryIfExists(directory); + deleteDirectoryIfExists(resolveQueryDirectory(queryId)); } public byte[] readSegment(String queryId, String planNodeId, int segmentId) throws IOException {
