Skip to content

Commit 57d4157

Browse files
authored
[To dev/1.3] Try delete sort tmp after driver is closed
(cherry picked from commit acaa72d)
1 parent 7ef7a7e commit 57d4157

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/FragmentInstanceExecution.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -306,9 +306,6 @@ private void initialize(IDriverScheduler scheduler, boolean isExplainAnalyze) {
306306

307307
clearShuffleSinkHandle(newState);
308308

309-
// delete tmp file if exists
310-
deleteTmpFile();
311-
312309
// close the driver after sink is aborted or closed because in driver.close() it
313310
// will try to call ISink.setNoMoreTsBlocks()
314311
for (IDriver driver : drivers) {
@@ -320,6 +317,9 @@ private void initialize(IDriverScheduler scheduler, boolean isExplainAnalyze) {
320317
// release file handlers
321318
context.releaseResourceWhenAllDriversAreClosed();
322319

320+
// delete tmp file if exists
321+
deleteTmpFile();
322+
323323
// release memory
324324
exchangeManager.deRegisterFragmentInstanceFromMemoryPool(
325325
instanceId.getQueryId().getId(), instanceId.getFragmentInstanceId(), true);

0 commit comments

Comments
 (0)