This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch new_object_type in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit f9a9bc251c3eb2557c3ec60e5c49e01b4ca5ed52 Author: shuwenwei <[email protected]> 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()); + } }
