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 eff18ae remove recover compaction
eff18ae is described below
commit eff18ae9dbe3fbb3e6aa8ff32eace2c10a8570f8
Author: qiaojialin <[email protected]>
AuthorDate: Wed Aug 4 23:12:53 2021 +0800
remove recover compaction
---
.../iotdb/db/engine/storagegroup/StorageGroupProcessor.java | 8 +++++---
1 file changed, 5 insertions(+), 3 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 2fdb61d..e959dad 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
@@ -536,9 +536,11 @@ public class StorageGroupProcessor {
logicalStorageGroupName,
virtualStorageGroupId);
try {
- CompactionMergeTaskPoolManager.getInstance()
- .submitTask(
- tsFileManagement.new
CompactionRecoverTask(this::closeCompactionRecoverCallBack));
+ if (config.getCompactionStrategy() ==
CompactionStrategy.LEVEL_COMPACTION) {
+ CompactionMergeTaskPoolManager.getInstance()
+ .submitTask(
+ tsFileManagement.new
CompactionRecoverTask(this::closeCompactionRecoverCallBack));
+ }
} catch (RejectedExecutionException e) {
this.closeCompactionRecoverCallBack(false, 0);
logger.error(