(iotdb) branch object_type updated: modify the log of removing object file

[shuwenwei]

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

shuwenwei pushed a commit to branch object_type
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/object_type by this push:
     new 9f6c771a03f modify the log of removing object file
9f6c771a03f is described below

commit 9f6c771a03ff0a8bda3960550950a72b716eeaca
Author: shuwenwei <s13979062...@gmail.com>
AuthorDate: Wed Aug 27 18:45:50 2025 +0800

    modify the log of removing object file
---
 .../java/org/apache/iotdb/db/utils/ObjectTypeUtils.java    | 14 ++++++++++----
 1 file changed, 10 insertions(+), 4 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/ObjectTypeUtils.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/ObjectTypeUtils.java
index 0531143fe8f..c153061a90d 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/ObjectTypeUtils.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/ObjectTypeUtils.java
@@ -66,19 +66,25 @@ public class ObjectTypeUtils {
     }
     File tmpFile = new File(file.get().getPath() + ".tmp");
     File bakFile = new File(file.get().getPath() + ".back");
-    logger.info("Remove object file {}", file.get().getAbsolutePath());
     for (int i = 0; i < 2; i++) {
       if (file.get().exists()) {
         FileMetrics.getInstance().decreaseObjectFileNum(1);
         FileMetrics.getInstance().decreaseObjectFileSize(file.get().length());
       }
       try {
-        Files.deleteIfExists(file.get().toPath());
-        Files.deleteIfExists(tmpFile.toPath());
-        Files.deleteIfExists(bakFile.toPath());
+        deleteObjectFile(file.get());
+        deleteObjectFile(tmpFile);
+        deleteObjectFile(bakFile);
       } catch (IOException e) {
         logger.error("Failed to remove object file {}", 
file.get().getAbsolutePath(), e);
       }
     }
   }
+
+  private static void deleteObjectFile(File file) throws IOException {
+    if (file.exists()) {
+      logger.info("Remove object file {}, size is {}(byte)", 
file.getAbsolutePath(), file.length());
+    }
+    Files.deleteIfExists(file.toPath());
+  }
 }