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 <[email protected]> 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 {
