This is an automated email from the ASF dual-hosted git repository. jiangtian pushed a commit to branch fix_insertion_compaction_selection in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit b0a8765aa4123b212641d519b7165d0db4d08d43 Author: Tian Jiang <[email protected]> AuthorDate: Wed Mar 4 15:43:42 2026 +0800 Fixed that InsertionCompactionSelection may skip a file deleted by another compaction --- .../selector/impl/RewriteCrossSpaceCompactionSelector.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/selector/impl/RewriteCrossSpaceCompactionSelector.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/selector/impl/RewriteCrossSpaceCompactionSelector.java index ffad8a487da..a7e6041ac98 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/selector/impl/RewriteCrossSpaceCompactionSelector.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/selector/impl/RewriteCrossSpaceCompactionSelector.java @@ -490,6 +490,12 @@ public class RewriteCrossSpaceCompactionSelector implements ICrossSpaceSelector nextSeqFileIndex = Math.min(nextSeqFileIndex, i); } if (!seqFile.containsDevice(deviceId)) { + // if the seqFile is deleted by another compaction concurrently, + // we cannot ensure whether the seqFile overlaps with the unseqFile. + // Let a later selection retry with compacted file. + if (seqFile.resource.isDeleted()) { + return result; + } continue; } DeviceInfo seqDeviceInfo = seqFile.getDeviceInfoById(deviceId);
