This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch FixSortTmp in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 074fa71380aa9d7265b642a888c45b18a2a9df63 Author: JackieTien97 <[email protected]> AuthorDate: Tue Jul 8 11:40:20 2025 +0800 Delete sort tmp --- .../queryengine/execution/fragment/FragmentInstanceExecution.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/FragmentInstanceExecution.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/FragmentInstanceExecution.java index 2bef0872c23..1094266fa39 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/FragmentInstanceExecution.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/FragmentInstanceExecution.java @@ -290,9 +290,6 @@ public class FragmentInstanceExecution { clearShuffleSinkHandle(newState); - // delete tmp file if exists - deleteTmpFile(); - // close the driver after sink is aborted or closed because in driver.close() it // will try to call ISink.setNoMoreTsBlocks() for (IDriver driver : drivers) { @@ -304,6 +301,9 @@ public class FragmentInstanceExecution { // release file handlers context.releaseResourceWhenAllDriversAreClosed(); + // delete tmp file if exists + deleteTmpFile(); + // release memory exchangeManager.deRegisterFragmentInstanceFromMemoryPool( instanceId.getQueryId().getId(), instanceId.getFragmentInstanceId(), true);
