[incubator-iotdb] branch new_series_reader_tsfileprocessor_test created (now 0c99af5)

[hx...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

hxd pushed a change to branch new_series_reader_tsfileprocessor_test
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.


      at 0c99af5  add log for debug

This branch includes the following new commits:

     new 0c99af5  add log for debug

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

[incubator-iotdb] 01/01: add log for debug

[hx...@apache.org]

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()
+                );
           }
 
         }