You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ta...@apache.org on 2021/08/04 01:58:10 UTC
[iotdb] branch autoai_debug updated: add memtable log
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 <TX...@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++) {