You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by qi...@apache.org on 2021/08/04 10:01:04 UTC
[iotdb] branch disable_compaction created (now 710781e)
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a change to branch disable_compaction
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
at 710781e only submit task in LEVEL_COMPACTION
This branch includes the following new commits:
new 710781e only submit task in LEVEL_COMPACTION
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[iotdb] 01/01: only submit task in LEVEL_COMPACTION
Posted by qi...@apache.org.
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 <64...@qq.com>
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 {