This is an automated email from the ASF dual-hosted git repository. marklau99 pushed a commit to branch IOTDB-4554 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 3cf9bdc06d5f34ee5cbfc2571bcc24010b1d804e Author: LiuXuxin <[email protected]> AuthorDate: Wed Sep 28 20:25:18 2022 +0800 do not submit compaction task when iotdb is not recover --- .../org/apache/iotdb/db/engine/compaction/CompactionTaskManager.java | 4 +++- 1 file changed, 3 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 117aee27ab..070f0224d1 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 @@ -29,6 +29,7 @@ import org.apache.iotdb.db.engine.compaction.constant.CompactionTaskStatus; import org.apache.iotdb.db.engine.compaction.task.AbstractCompactionTask; import org.apache.iotdb.db.engine.compaction.task.CompactionTaskSummary; import org.apache.iotdb.db.service.IService; +import org.apache.iotdb.db.service.IoTDB; import org.apache.iotdb.db.service.ServiceType; import org.apache.iotdb.db.utils.TestOnly; import org.apache.iotdb.db.utils.datastructure.FixedPriorityBlockingQueue; @@ -248,7 +249,8 @@ public class CompactionTaskManager implements IService { */ public synchronized void submitTaskFromTaskQueue() { try { - while (currentTaskNum.get() + while (IoTDB.activated + && currentTaskNum.get() < IoTDBDescriptor.getInstance().getConfig().getConcurrentCompactionThread() && !candidateCompactionTaskQueue.isEmpty()) { AbstractCompactionTask task = candidateCompactionTaskQueue.take();
