[iotdb] branch autoai_debug updated: add memtable log

[tanxinyu]

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

tanxinyu pushed a commit to branch autoai_debug
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/autoai_debug by this push:
     new e3ff9c1  add memtable log
e3ff9c1 is described below

commit e3ff9c196e8575ae50c3ebe7857bbb01c48e38fc
Author: LebronAl <txypot...@gmail.com>
AuthorDate: Wed Aug 4 09:57:38 2021 +0800

    add memtable log
---
 .../iotdb/db/engine/storagegroup/TsFileProcessor.java       | 13 +++++++++----
 1 file changed, 9 insertions(+), 4 deletions(-)

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 7d503e6..4e165c9 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
@@ -252,16 +252,21 @@ public class TsFileProcessor {
       throw new WriteProcessException(e);
     }
     try {
+      long startTime = System.nanoTime();
       workMemTable.insertTablet(insertTabletPlan, start, end);
-      long startTime = System.currentTimeMillis();
+      long elapse = System.nanoTime() - startTime;
+      if (elapse > 5_000_000_000L) {
+        logger.error("write memtable slowly : cost {}ms", elapse / 1_000_000L);
+      }
+      startTime = System.nanoTime();
       if (IoTDBDescriptor.getInstance().getConfig().isEnableWal()) {
         insertTabletPlan.setStart(start);
         insertTabletPlan.setEnd(end);
         getLogNode().write(insertTabletPlan);
       }
-      long elapsed = System.currentTimeMillis() - startTime;
-      if (elapsed > 5000) {
-        logger.error("write wal slowly : cost {}ms", elapsed);
+      elapse = System.nanoTime() - startTime;
+      if (elapse > 5_000_000_000L) {
+        logger.error("write wal slowly : cost {}ms", elapse / 1_000_000L);
       }
     } catch (Exception e) {
       for (int i = start; i < end; i++) {