[incubator-iotdb] branch new_series_reader_tsfileprocessor_test updated: add log for debug

[hxd]

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


The following commit(s) were added to 
refs/heads/new_series_reader_tsfileprocessor_test by this push:
     new b8586a0  add log for debug
b8586a0 is described below

commit b8586a0ee04dfe23dd8cbd5c1306c59c4d6eaa00
Author: xiangdong huang <saint...@gmail.com>
AuthorDate: Fri Feb 21 12:21:10 2020 +0800

    add log for debug
---
 .../main/java/org/apache/iotdb/db/engine/flush/FlushManager.java    | 2 ++
 .../org/apache/iotdb/db/engine/storagegroup/TsFileProcessor.java    | 6 +++---
 2 files changed, 5 insertions(+), 3 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 a83a877..0bc23ab 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
@@ -104,6 +104,8 @@ public class FlushManager implements FlushManagerMBean, 
IService {
         tsFileProcessorQueue.add(tsFileProcessor);
         tsFileProcessor.setManagedByFlushManager(true);
         flushPool.submit(new FlushThread());
+      } else {
+        logger.info("tsFileProcessor {} is already in the flushPool", 
tsFileProcessor.getStorageGroupName());
       }
     }
   }
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 9bfb31e..c82751f 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
@@ -291,7 +291,7 @@ public class TsFileProcessor {
                 (System.currentTimeMillis() - startTime)/1000,
                 flushingMemTables.size(),
                 flushingMemTables.getFirst(),
-                FlushManager.getInstance().toString()
+                FlushManager.getInstance()
                 );
           }
 
@@ -324,7 +324,7 @@ public class TsFileProcessor {
       IMemTable tmpMemTable = workMemTable == null ? new NotifyFlushMemTable() 
: workMemTable;
       if (logger.isDebugEnabled()) {
         if (tmpMemTable.isSignalMemTable()) {
-          logger.debug(
+          logger.error(
               "storage group {} add a signal memtable into flushing memtable 
list when async close",
               storageGroupName);
         } else {
@@ -352,7 +352,7 @@ public class TsFileProcessor {
     try {
       tmpMemTable = workMemTable == null ? new NotifyFlushMemTable() : 
workMemTable;
       if (tmpMemTable.isSignalMemTable()) {
-        logger.debug("add a signal memtable into flushing memtable list when 
sync flush");
+        logger.error("add a signal memtable into flushing memtable list when 
sync flush");
       }
       addAMemtableIntoFlushingList(tmpMemTable);
     } finally {