[iotdb] branch add_insert_time updated: add writelock、wal、memtable time (#4476)

[haonan]

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

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


The following commit(s) were added to refs/heads/add_insert_time by this push:
     new ef78a3f  add writelock、wal、memtable time (#4476)
ef78a3f is described below

commit ef78a3fa2edb44b126ff698aacfdd2efd8ed60c7
Author: Alan Choo <43991780+heimi...@users.noreply.github.com>
AuthorDate: Fri Nov 26 15:41:47 2021 +0800

    add writelock、wal、memtable time (#4476)
---
 .../apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java   | 2 ++
 .../org/apache/iotdb/db/engine/storagegroup/TsFileProcessor.java     | 5 ++++-
 2 files changed, 6 insertions(+), 1 deletion(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java
 
b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java
index 8361382..f1c9e31 100755
--- 
a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java
@@ -808,7 +808,9 @@ public class StorageGroupProcessor {
    */
   @SuppressWarnings("squid:S3776") // Suppress high Cognitive Complexity 
warning
   public void insertTablet(InsertTabletPlan insertTabletPlan) throws 
BatchProcessException {
+    long beforeGetWriteLock = System.currentTimeMillis();
     writeLock("insertTablet");
+    logger.info("Get writeLock cost: {} ms", System.currentTimeMillis() - 
beforeGetWriteLock);
     try {
       TSStatus[] results = new TSStatus[insertTabletPlan.getRowCount()];
       Arrays.fill(results, RpcUtils.SUCCESS_STATUS);
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 2fba8da..66d020b 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
@@ -255,6 +255,7 @@ public class TsFileProcessor {
       throw new WriteProcessException(e);
     }
 
+    long beforeWAL = System.currentTimeMillis();
     try {
       if (IoTDBDescriptor.getInstance().getConfig().isEnableWal()) {
         insertTabletPlan.setStart(start);
@@ -270,7 +271,8 @@ public class TsFileProcessor {
       }
       throw new WriteProcessException(e);
     }
-
+    long beforeMemtable = System.currentTimeMillis();
+    logger.info("write WAL cost: {} ms", beforeMemtable - beforeWAL);
     try {
       workMemTable.insertTablet(insertTabletPlan, start, end);
     } catch (WriteProcessException e) {
@@ -279,6 +281,7 @@ public class TsFileProcessor {
       }
       throw new WriteProcessException(e);
     }
+    logger.info("write memtable cost: {} ms", System.currentTimeMillis() - 
beforeMemtable);
 
     for (int i = start; i < end; i++) {
       results[i] = RpcUtils.SUCCESS_STATUS;