You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by hx...@apache.org on 2022/12/26 01:44:05 UTC
[iotdb] 01/02: add more log to show blocked jenkins task
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 <hx...@timecho.com>
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"/>