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 2020/02/20 17:31:05 UTC
[incubator-iotdb] 01/01: add log for debug
This is an automated email from the ASF dual-hosted git repository.
hxd pushed a commit to branch new_series_reader_tsfileprocessor_test
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
commit 0c99af5749513bc6dfbcb28c8ca94da542b46b26
Author: xiangdong huang <sa...@gmail.com>
AuthorDate: Fri Feb 21 01:30:41 2020 +0800
add log for debug
---
.../main/java/org/apache/iotdb/db/engine/flush/FlushManager.java | 6 ++++++
.../org/apache/iotdb/db/engine/storagegroup/TsFileProcessor.java | 6 ++++--
2 files changed, 10 insertions(+), 2 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/engine/flush/FlushManager.java b/server/src/main/java/org/apache/iotdb/db/engine/flush/FlushManager.java
index 8c224e0..a83a877 100644
--- a/server/src/main/java/org/apache/iotdb/db/engine/flush/FlushManager.java
+++ b/server/src/main/java/org/apache/iotdb/db/engine/flush/FlushManager.java
@@ -122,4 +122,10 @@ public class FlushManager implements FlushManagerMBean, IService {
private static FlushManager instance = new FlushManager();
}
+
+ public String toString() {
+ return String.format("TSProcessors in the queue: %d, TaskPool size %d + %d,",
+ tsFileProcessorQueue.size(), flushPool.getWorkingTasksNumber(),
+ flushPool.getWaitingTasksNumber());
+ }
}
diff --git a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessor.java b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessor.java
index 4f0ffdb..6efcae2 100644
--- a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessor.java
+++ b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessor.java
@@ -286,9 +286,11 @@ public class TsFileProcessor {
while (!flushingMemTables.isEmpty()) {
flushingMemTables.wait(60_000);
if (System.currentTimeMillis() - startTime > 60_000) {
- logger.warn("{} has spent {}s for waiting flushing one memtable; {} left.",
+ logger.warn("{} has spent {}s for waiting flushing one memtable; {} left. FlushingManager info: {}",
this.tsFileResource.getFile().getAbsolutePath(),
- (System.currentTimeMillis() - startTime)/1000,flushingMemTables.size());
+ (System.currentTimeMillis() - startTime)/1000, flushingMemTables.size(),
+ FlushManager.getInstance().toString()
+ );
}
}