This is an automated email from the ASF dual-hosted git repository. shuwenwei pushed a commit to branch reduceErrorLogWhenStoppingCompactionService in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit e5e21c132ddf0167e93d76e2394d5342e5c50f7a 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 cf59a19552b..dd37f626d70 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 @@ -164,7 +164,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,
