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

haonan 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 b546aff42d7 remove bin.tmp when recover
b546aff42d7 is described below

commit b546aff42d766cd6d5a2853215f6085f94239952
Author: HTHou <[email protected]>
AuthorDate: Mon Jul 7 11:20:46 2025 +0800

    remove bin.tmp when recover
---
 .../org/apache/iotdb/db/storageengine/dataregion/DataRegion.java    | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
index be2917ffd32..3da2e466177 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
@@ -828,6 +828,12 @@ public class DataRegion implements IDataRegionForQuery {
                           Long.parseLong(
                               f.getName().substring(0, f.getName().length() - 
4).split("-")[2])));
             }
+            File[] objectTmpFileInThisFolder =
+                fsFactory.listFilesBySuffix(partitionFolder.getAbsolutePath(), 
".bin.tmp");
+            for (File f : objectTmpFileInThisFolder) {
+              // remove bin.tmp
+              Files.delete(f.toPath());
+            }
           }
         }
       }

Reply via email to