This is an automated email from the ASF dual-hosted git repository. shuwenwei pushed a commit to branch reduceErrorLogWhenStoppingCompactionService-1.3 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit eed4c9ef17bb5d24804686d11f8541338d586ae5 Author: shuwenwei <[email protected]> AuthorDate: Fri Nov 14 14:58:28 2025 +0800 reduce error log when compaction service is stopped --- .../dataregion/compaction/execute/task/AbstractCompactionTask.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/task/AbstractCompactionTask.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/task/AbstractCompactionTask.java index 8d7bbd2d14d..fba00fae125 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/task/AbstractCompactionTask.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/task/AbstractCompactionTask.java @@ -165,7 +165,8 @@ public abstract class AbstractCompactionTask { } else if (e instanceof InterruptedException || Thread.interrupted() || e instanceof StopReadTsFileByInterruptException - || !tsFileManager.isAllowCompaction()) { + || !tsFileManager.isAllowCompaction() + || CompactionTaskManager.getInstance().isStopAllCompactionWorker()) { logger.warn( "{}-{} [Compaction] {} task interrupted", storageGroupName,
