(iotdb) branch master updated: Fix concurrent delete and flush error (#17026)

[ji...@apache.org]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new ae2793d5cdc Fix concurrent delete and flush error (#17026)
ae2793d5cdc is described below

commit ae2793d5cdc155fcafdcb64a3da3724e15e5a43b
Author: Haonan <hh...@outlook.com>
AuthorDate: Wed Jan 14 17:04:26 2026 +0800

    Fix concurrent delete and flush error (#17026)
---
 .../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 746e042ab14..b8101fbd443 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
@@ -3249,6 +3249,12 @@ public class DataRegion implements IDataRegionForQuery {
         continue;
       }
 
+      // the tsfile may not be closed here, it should not be added in deletedByFiles
+      if (!sealedTsFile.isClosed()) {
+        deletedByMods.add(sealedTsFile);
+        continue;
+      }
+
       ITimeIndex timeIndex = sealedTsFile.getTimeIndex();
 
       if ((timeIndex instanceof ArrayDeviceTimeIndex)