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 bcdfe07  add log for debug
bcdfe07 is described below

commit bcdfe07b4bfdf2f2dc373151b26f086a0ebd5b38
Author: xiangdong huang <[email protected]>
AuthorDate: Fri Feb 21 19:50:23 2020 +0800

    add log for debug
---
 .../java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessor.java  | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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 c5eb331..9777023 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
@@ -487,11 +487,12 @@ public class TsFileProcessor {
         getLogNode().notifyEndFlush();
       }
     }
-
+    logger.error("try get lock to release a memtable (signal={})", 
memTableToFlush.isSignalMemTable());
     // for sync flush
     synchronized (memTableToFlush) {
       releaseFlushedMemTable(memTableToFlush);
       memTableToFlush.notifyAll();
+      logger.error("released a memtable (signal={}), flushingMemtables size 
={}", memTableToFlush.isSignalMemTable(), flushingMemTables.size());
     }
 
     if (shouldClose && flushingMemTables.isEmpty()) {

Reply via email to