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

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


The following commit(s) were added to refs/heads/ty/cleanTmp by this push:
     new 8186310f54f Clean up tmp dirs of udf and sort while starting up
8186310f54f is described below

commit 8186310f54ff46cf12a55dd3aa2828cae11813f7
Author: JackieTien97 <[email protected]>
AuthorDate: Fri Mar 27 17:13:15 2026 +0800

    Clean up tmp dirs of udf and sort while starting up
---
 .../iotdb/db/service/TemporaryQueryDataFileService.java    |  2 +-
 .../apache/iotdb/commons/executable/ExecutableManager.java | 14 ++++++--------
 2 files changed, 7 insertions(+), 9 deletions(-)

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 d21e0f134a3..c8150ea9295 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
@@ -126,7 +126,7 @@ public class TemporaryQueryDataFileService implements 
IService {
     try {
       
FileUtils.deleteDirectory(SystemFileFactory.INSTANCE.getFile(TEMPORARY_FILE_DIR));
     } catch (IOException e) {
-      logger.warn("Failed to delete temp dir {}: {}", TEMPORARY_FILE_DIR, e);
+      logger.warn("Failed to delete temp dir {}.", TEMPORARY_FILE_DIR, e);
     }
   }
 
diff --git 
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/executable/ExecutableManager.java
 
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/executable/ExecutableManager.java
index f0a3fb33976..86e153a511f 100644
--- 
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/executable/ExecutableManager.java
+++ 
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/executable/ExecutableManager.java
@@ -86,7 +86,8 @@ public class ExecutableManager {
       for (String uriString : uris) {
         final URL url = new URI(uriString).toURL();
         final String fileName = uriString.substring(uriString.lastIndexOf("/") 
+ 1);
-        final String destination = temporaryLibRoot + File.separator + 
requestId + File.separator + fileName;
+        final String destination =
+            temporaryLibRoot + File.separator + requestId + File.separator + 
fileName;
         FileUtils.copyURLToFile(url, 
FSFactoryProducer.getFSFactory().getFile(destination));
       }
     } catch (Exception e) {
@@ -210,8 +211,7 @@ public class ExecutableManager {
   }
 
   /**
-   * Create and save the file if the specified file does not exist, or this 
method
-   * will override the
+   * Create and save the file if the specified file does not exist, or this 
method will override the
    * existing file.
    */
   protected void saveToDir(ByteBuffer byteBuffer, String destination) throws 
IOException {
@@ -239,8 +239,7 @@ public class ExecutableManager {
 
   /**
    * @param byteBuffer file
-   * @param fileName   The name of the file. Absolute Path will be libRoot +
-   *                   File_Separator + fileName
+   * @param fileName The name of the file. Absolute Path will be libRoot + 
File_Separator + fileName
    */
   public void saveToLibDir(ByteBuffer byteBuffer, String fileName) throws 
IOException {
     String destination = this.libRoot + File.separator + fileName;
@@ -249,9 +248,8 @@ public class ExecutableManager {
 
   /**
    * @param byteBuffer file
-   * @param fileName   Absolute Path will be libRoot + File_Separator +
-   *                   INSTALL_DIR + File.separator +
-   *                   fileName
+   * @param fileName Absolute Path will be libRoot + File_Separator + 
INSTALL_DIR + File.separator +
+   *     fileName
    */
   public void saveToInstallDir(ByteBuffer byteBuffer, String fileName) throws 
IOException {
     String destination = this.libRoot + File.separator + INSTALL_DIR + 
File.separator + fileName;

Reply via email to