This is an automated email from the ASF dual-hosted git repository. jiangtian pushed a commit to branch no_new_compaction_mods in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 876bd1b75fae12e0aee39aac0ded46cfedc02deb Author: Tian Jiang <[email protected]> AuthorDate: Mon Apr 7 11:52:25 2025 +0800 Do not add new compaction mod file in deletion --- .../org/apache/iotdb/db/storageengine/dataregion/DataRegion.java | 6 ------ 1 file changed, 6 deletions(-) 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 6fb11196d71..59e179fcff1 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 @@ -2606,9 +2606,6 @@ public class DataRegion implements IDataRegionForQuery { continue; } - if (sealedTsFile.isCompacting()) { - involvedModificationFiles.add(sealedTsFile.getCompactionModFile()); - } involvedModificationFiles.add(sealedTsFile.getModFileForWrite()); } @@ -2658,9 +2655,6 @@ public class DataRegion implements IDataRegionForQuery { for (TsFileResource tsFileResource : deletedByMods) { if (tsFileResource.isClosed() || !tsFileResource.getProcessor().deleteDataInMemory(modEntry)) { - if (tsFileResource.isCompacting()) { - involvedModificationFiles.add(tsFileResource.getCompactionModFile()); - } involvedModificationFiles.add(tsFileResource.getModFileForWrite()); } // else do nothing }
