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;