[incubator-iotdb] branch zc_test updated: add log for flushFuture.get()

[liurui]

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

liurui pushed a commit to branch zc_test
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git


The following commit(s) were added to refs/heads/zc_test by this push:
     new f18bc54  add log for flushFuture.get()
f18bc54 is described below

commit f18bc54324cb54b486ded636b7ab92239bdbbc21
Author: liuruiyiyang <245422...@qq.com>
AuthorDate: Mon Jun 3 14:25:34 2019 +0800

    add log for flushFuture.get()
---
 .../iotdb/db/engine/bufferwrite/BufferWriteProcessor.java      | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git 
a/iotdb/src/main/java/org/apache/iotdb/db/engine/bufferwrite/BufferWriteProcessor.java
 
b/iotdb/src/main/java/org/apache/iotdb/db/engine/bufferwrite/BufferWriteProcessor.java
index 1809cfb..1430512 100644
--- 
a/iotdb/src/main/java/org/apache/iotdb/db/engine/bufferwrite/BufferWriteProcessor.java
+++ 
b/iotdb/src/main/java/org/apache/iotdb/db/engine/bufferwrite/BufferWriteProcessor.java
@@ -363,11 +363,21 @@ public class BufferWriteProcessor extends Processor {
     lastFlushTime = System.nanoTime();
     // check value count
     // waiting for the end of last flush operation.
+    long beforeFlushFutureGetTime = System.currentTimeMillis();
     try {
       flushFuture.get();
     } catch (InterruptedException | ExecutionException e) {
       throw new IOException(e);
     }
+    if (LOGGER.isInfoEnabled()) {
+      long afterFlushFutureGetTime = System.currentTimeMillis();
+      LOGGER.info(
+          "The BufferWrite processor ,{},: before flushFuture.get() time is 
,{}, before flushFuture.get() time is ,{}, "
+              + "flushFuture.get() blocking time interval is ,{}, sec", 
getProcessorName(),
+          
DatetimeUtils.convertMillsecondToZonedDateTime(beforeFlushFutureGetTime),
+          
DatetimeUtils.convertMillsecondToZonedDateTime(afterFlushFutureGetTime),
+          (afterFlushFutureGetTime - beforeFlushFutureGetTime) / 1000.0);
+    }
     if (valueCount > 0) {
       // update the lastUpdatetime, prepare for flush
       try {