Skip to content

Commit ae2793d

Browse files
authored
Fix concurrent delete and flush error (#17026)
1 parent fe0d0f3 commit ae2793d

File tree

1 file changed

+6
-0
lines changed
  • iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion

1 file changed

+6
-0
lines changed

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3249,6 +3249,12 @@ private void deleteDataInSealedFiles(Collection<TsFileResource> sealedTsFiles, M
32493249
continue;
32503250
}
32513251

3252+
// the tsfile may not be closed here, it should not be added in deletedByFiles
3253+
if (!sealedTsFile.isClosed()) {
3254+
deletedByMods.add(sealedTsFile);
3255+
continue;
3256+
}
3257+
32523258
ITimeIndex timeIndex = sealedTsFile.getTimeIndex();
32533259

32543260
if ((timeIndex instanceof ArrayDeviceTimeIndex)

0 commit comments

Comments
 (0)