This is an automated email from the ASF dual-hosted git repository. hxd pushed a commit to branch jenkins-disable-integration in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 2c2323ebc7d4a8089b81735450ed38e3976a35ff Author: xiangdong huang <[email protected]> AuthorDate: Mon Dec 26 09:43:27 2022 +0800 add more log to show blocked jenkins task --- .../org/apache/iotdb/db/engine/compaction/CompactionTaskManager.java | 5 +++++ .../org/apache/iotdb/db/engine/storagegroup/TsFileProcessorTest.java | 1 + server/src/test/resources/logback-test.xml | 1 + 3 files changed, 7 insertions(+) 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 1e5424bc51..b68f8c8042 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 @@ -151,6 +151,7 @@ public class CompactionTaskManager implements IService { WrappedThreadPoolExecutor tmpThreadPool = taskExecutionPool; taskExecutionPool = null; candidateCompactionTaskQueue.clear(); + int totalSleep = 0; while (true) { int totalSize = 0; for (Map<AbstractCompactionTask, Future<CompactionTaskSummary>> taskMap : @@ -160,6 +161,10 @@ public class CompactionTaskManager implements IService { if (totalSize > 0) { try { Thread.sleep(100); + totalSleep++; + if (totalSleep % 100 == 0) { + logger.info("already waite {} seconds for all task finish", totalSleep/10); + } } catch (InterruptedException e) { logger.error("Interrupted when waiting all task finish", e); break; diff --git a/server/src/test/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessorTest.java b/server/src/test/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessorTest.java index 3ecae7e3a3..f5f7a6b69c 100644 --- a/server/src/test/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessorTest.java +++ b/server/src/test/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessorTest.java @@ -97,6 +97,7 @@ public class TsFileProcessorTest { public void tearDown() throws Exception { logger.info("tear down..."); EnvironmentUtils.cleanEnv(); + logger.info("tear down cleanEnv Done..."); EnvironmentUtils.cleanDir(TestConstant.OUTPUT_DATA_DIR); logger.info("tear down done."); } diff --git a/server/src/test/resources/logback-test.xml b/server/src/test/resources/logback-test.xml index 6f0bf56626..37728d5e92 100644 --- a/server/src/test/resources/logback-test.xml +++ b/server/src/test/resources/logback-test.xml @@ -55,6 +55,7 @@ <logger name="org.apache.iotdb.db.engine.compaction.cross.rewrite.task" level="ERROR"/> <logger name="io.moquette.broker.metrics.MQTTMessageLogger" level="ERROR"/> <logger name="org.apache.iotdb.db.engine" level="INFO"/> + <logger name="org.apache.iotdb.db.engine.compaction.CompactionTaskManager" level="INFO"/> <logger name="DETAILED_FAILURE_QUERY_TRACE" level="ERROR"/> <root level="ERROR"> <appender-ref ref="stdout"/>
