[iotdb] branch IOTDB-3651 updated: not initialize thread pool in CompactionTaskManager if all compaction is disable

[marklau99]

This is an automated email from the ASF dual-hosted git repository.

marklau99 pushed a commit to branch IOTDB-3651
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/IOTDB-3651 by this push:
     new ee9fd80ef4 not initialize thread pool in CompactionTaskManager if all 
compaction is disable
ee9fd80ef4 is described below

commit ee9fd80ef412d5a65fcc0506f6c5c4aa70096d8e
Author: Liu Xuxin <liuxu...@outlook.com>
AuthorDate: Tue Jun 28 00:00:55 2022 +0800

    not initialize thread pool in CompactionTaskManager if all compaction is 
disable
---
 .../apache/iotdb/db/engine/compaction/CompactionTaskManager.java  | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/engine/compaction/CompactionTaskManager.java
 
b/server/src/main/java/org/apache/iotdb/db/engine/compaction/CompactionTaskManager.java
index 0af38831ef..34bcd01de8 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/engine/compaction/CompactionTaskManager.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/engine/compaction/CompactionTaskManager.java
@@ -27,6 +27,7 @@ import org.apache.iotdb.commons.conf.IoTDBConstant;
 import org.apache.iotdb.commons.service.IService;
 import org.apache.iotdb.commons.service.ServiceType;
 import org.apache.iotdb.commons.utils.TestOnly;
+import org.apache.iotdb.db.conf.IoTDBConfig;
 import org.apache.iotdb.db.conf.IoTDBDescriptor;
 import 
org.apache.iotdb.db.engine.compaction.comparator.DefaultCompactionTaskComparatorImpl;
 import org.apache.iotdb.db.engine.compaction.constant.CompactionTaskStatus;
@@ -85,6 +86,8 @@ public class CompactionTaskManager implements IService {
 
   private final RateLimiter mergeWriteRateLimiter = 
RateLimiter.create(Double.MAX_VALUE);
 
+  private final IoTDBConfig config = IoTDBDescriptor.getInstance().getConfig();
+
   public static CompactionTaskManager getInstance() {
     return INSTANCE;
   }
@@ -92,7 +95,10 @@ public class CompactionTaskManager implements IService {
   @Override
   public synchronized void start() {
     if (taskExecutionPool == null
-        && 
IoTDBDescriptor.getInstance().getConfig().getConcurrentCompactionThread() > 0) {
+        && 
IoTDBDescriptor.getInstance().getConfig().getConcurrentCompactionThread() > 0
+        && (config.isEnableSeqSpaceCompaction()
+            || config.isEnableUnseqSpaceCompaction()
+            || config.isEnableCrossSpaceCompaction())) {
       this.taskExecutionPool =
           (WrappedThreadPoolExecutor)
               IoTDBThreadPoolFactory.newFixedThreadPool(