You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2023/08/18 01:41:26 UTC
[iotdb] branch master updated: Override existing jar instead of deleting it when registering UDF
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new 052ff28cf89 Override existing jar instead of deleting it when registering UDF
052ff28cf89 is described below
commit 052ff28cf891aa5658ea04aa28676e5f4883c43c
Author: Liao Lanyu <14...@qq.com>
AuthorDate: Fri Aug 18 09:41:19 2023 +0800
Override existing jar instead of deleting it when registering UDF
---
.../apache/iotdb/commons/executable/ExecutableManager.java | 11 +++++++++--
1 file changed, 9 insertions(+), 2 deletions(-)
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 0f195086230..4a730d2a5fa 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
@@ -223,11 +223,18 @@ public class ExecutableManager {
}
}
+ /**
+ * 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 {
try {
Path path = Paths.get(destination);
- Files.deleteIfExists(path);
- Files.createFile(path);
+ if (!Files.exists(path)) {
+ Files.createFile(path);
+ }
+ // FileOutPutStream is not in append mode by default, so the file will be overridden if it
+ // already exists.
try (FileOutputStream outputStream = new FileOutputStream(destination)) {
outputStream.getChannel().write(byteBuffer);
}