You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ji...@apache.org on 2026/06/03 11:21:50 UTC
(iotdb) 01/01: Ignore non-exist object folder when removing a region
This is an automated email from the ASF dual-hosted git repository.
jt2594838 pushed a commit to branch ignore_nonexist_object_folder
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 80243341eb0967431a7144177549b5094bfed4fc
Author: Tian Jiang <jt...@163.com>
AuthorDate: Wed Jun 3 19:08:02 2026 +0800
Ignore non-exist object folder when removing a region
---
.../java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java | 4 ++++
1 file changed, 4 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 b5113cb4406..7289e83cc9f 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
@@ -2307,6 +2307,10 @@ public class DataRegion implements IDataRegionForQuery {
private void deleteAllObjectFiles(List<String> folders) {
for (String objectFolder : folders) {
File dataRegionObjectFolder = fsFactory.getFile(objectFolder, dataRegionIdString);
+ if (!dataRegionObjectFolder.exists()) {
+ continue;
+ }
+
AtomicLong totalSize = new AtomicLong(0);
AtomicInteger count = new AtomicInteger(0);
try (Stream<Path> paths = Files.walk(dataRegionObjectFolder.toPath())) {