This is an automated email from the ASF dual-hosted git repository. qiaojialin pushed a commit to branch disable_compaction in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 710781e7f350efdda8294f6637a81ca4a1bb4ffc Author: qiaojialin <[email protected]> AuthorDate: Wed Aug 4 18:00:37 2021 +0800 only submit task in LEVEL_COMPACTION --- .../iotdb/db/engine/storagegroup/StorageGroupProcessor.java | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java index 6e589d3..43f4dbc 100755 --- a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java +++ b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java @@ -24,6 +24,7 @@ import org.apache.iotdb.db.conf.IoTDBDescriptor; import org.apache.iotdb.db.conf.directories.DirectoryManager; import org.apache.iotdb.db.engine.StorageEngine; import org.apache.iotdb.db.engine.compaction.CompactionMergeTaskPoolManager; +import org.apache.iotdb.db.engine.compaction.CompactionStrategy; import org.apache.iotdb.db.engine.compaction.StorageGroupCompactionTask; import org.apache.iotdb.db.engine.compaction.TsFileManagement; import org.apache.iotdb.db.engine.fileSystem.SystemFileFactory; @@ -1952,10 +1953,12 @@ public class StorageGroupProcessor { "signal closing storage group condition in {}", logicalStorageGroupName + "-" + virtualStorageGroupId); - CompactionMergeTaskPoolManager.getInstance() - .submitTask( - new CompactionOnePartitionTask( - logicalStorageGroupName, tsFileProcessor.getTimeRangeId())); + if (config.getCompactionStrategy() == CompactionStrategy.LEVEL_COMPACTION) { + CompactionMergeTaskPoolManager.getInstance() + .submitTask( + new CompactionOnePartitionTask( + logicalStorageGroupName, tsFileProcessor.getTimeRangeId())); + } } public class CompactionOnePartitionTask extends StorageGroupCompactionTask {
