This is an automated email from the ASF dual-hosted git repository. sunzesong pushed a commit to branch hdfs_delete in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit ddd8ccb8ce21a8bfd21d80f9a80c3add2f856a0a Author: samperson1997 <[email protected]> AuthorDate: Thu Mar 25 23:54:44 2021 +0800 Fix Files.deleteIfExists() doesn't work for HDFS file --- .../java/org/apache/iotdb/db/engine/storagegroup/TsFileResource.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileResource.java b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileResource.java index 8a9cd3a..35b4a45 100644 --- a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileResource.java +++ b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileResource.java @@ -254,7 +254,9 @@ public class TsFileResource { } File src = fsFactory.getFile(file + RESOURCE_SUFFIX + TEMP_SUFFIX); File dest = fsFactory.getFile(file + RESOURCE_SUFFIX); - Files.deleteIfExists(dest.toPath()); + if (dest.exists()) { + dest.delete(); + } fsFactory.moveFile(src, dest); }
