[iotdb] branch UDFDirRemove created (now 0e413a6e8d6)

[ja...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

jackietien pushed a change to branch UDFDirRemove
in repository https://gitbox.apache.org/repos/asf/iotdb.git


      at 0e413a6e8d6 [IOTDB-6104] Remove tmp directory for udf query completely while query end

This branch includes the following new commits:

     new 0e413a6e8d6 [IOTDB-6104] Remove tmp directory for udf query completely while query end

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

[iotdb] 01/01: [IOTDB-6104] Remove tmp directory for udf query completely while query end

[ja...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

jackietien pushed a commit to branch UDFDirRemove
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit 0e413a6e8d61d036024167c4b6c0749e60fab00b
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Tue Aug 8 20:49:24 2023 +0800

    [IOTDB-6104] Remove tmp directory for udf query completely while query end
---
 .../java/org/apache/iotdb/db/service/TemporaryQueryDataFileService.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/TemporaryQueryDataFileService.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/TemporaryQueryDataFileService.java
index 0c8418eb170..9c0eef89a8d 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/TemporaryQueryDataFileService.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/TemporaryQueryDataFileService.java
@@ -83,7 +83,7 @@ public class TemporaryQueryDataFileService implements IService {
       }
     }
     try {
-      FileUtils.cleanDirectory(SystemFileFactory.INSTANCE.getFile(getDirName(queryId)));
+      FileUtils.deleteDirectory(SystemFileFactory.INSTANCE.getFile(getDirName(queryId)));
     } catch (IOException e) {
       logger.warn(
           String.format("Failed to clean dir in method deregister(%s), because %s", queryId, e));