You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by li...@apache.org on 2019/06/03 06:31:34 UTC
[incubator-iotdb] branch zc_long_tail_debug created (now dd8ec7a)
This is an automated email from the ASF dual-hosted git repository.
liurui pushed a change to branch zc_long_tail_debug
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.
at dd8ec7a add log for
This branch includes the following new commits:
new dd8ec7a add log for
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[incubator-iotdb] 01/01: add log for
Posted by 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 {