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:03:32 UTC
[iotdb] branch autoai updated: only submit task in LEVEL_COMPACTION
(#3684)
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a commit to branch autoai
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/autoai by this push:
new 6c2a833 only submit task in LEVEL_COMPACTION (#3684)
6c2a833 is described below
commit 6c2a8332d2ed886fb6cb5852dfb47ef1058c68cd
Author: Jialin Qiao <qj...@mails.tsinghua.edu.cn>
AuthorDate: Wed Aug 4 18:03:11 2021 +0800
only submit task in LEVEL_COMPACTION (#3684)
---
.../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 {