Skip to content

Commit acaa72d

Browse files
authored
Try delete sort tmp after driver is closed
1 parent 4cc6085 commit acaa72d

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

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
@@ -290,9 +290,6 @@ private void initialize(IDriverScheduler scheduler, boolean isExplainAnalyze) {
290290

291291
clearShuffleSinkHandle(newState);
292292

293-
// delete tmp file if exists
294-
deleteTmpFile();
295-
296293
// close the driver after sink is aborted or closed because in driver.close() it
297294
// will try to call ISink.setNoMoreTsBlocks()
298295
for (IDriver driver : drivers) {
@@ -304,6 +301,9 @@ private void initialize(IDriverScheduler scheduler, boolean isExplainAnalyze) {
304301
// release file handlers
305302
context.releaseResourceWhenAllDriversAreClosed();
306303

304+
// delete tmp file if exists
305+
deleteTmpFile();
306+
307307
// release memory
308308
exchangeManager.deRegisterFragmentInstanceFromMemoryPool(
309309
instanceId.getQueryId().getId(), instanceId.getFragmentInstanceId(), true);

0 commit comments

Comments
 (0)