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

[li...@apache.org]

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

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

commit dd8ec7ad08174eeccf586fe5dc0f342f64aba5e8
Author: liuruiyiyang <24...@qq.com>
AuthorDate: Mon Jun 3 14:31:11 2019 +0800

    add log for
---
 .../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 {