You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by su...@apache.org on 2021/03/25 15:55:28 UTC
[iotdb] 01/01: Fix Files.deleteIfExists() doesn't work for HDFS file
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 <sz...@mails.tsinghua.edu.cn>
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);
}