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(

Reply via email to