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/02 13:44:57 UTC
[iotdb] branch autoai_debug updated: add supplier 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 99584fc add supplier log
99584fc is described below
commit 99584fc734ab0ad9d87a28e5f81fd867667416d8
Author: LebronAl <TX...@gmail.com>
AuthorDate: Mon Aug 2 21:43:39 2021 +0800
add supplier log
---
.../org/apache/iotdb/db/engine/storagegroup/TsFileProcessor.java | 5 +++++
.../org/apache/iotdb/db/writelog/node/ExclusiveWriteLogNode.java | 3 +--
2 files changed, 6 insertions(+), 2 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 4675ecd..7d503e6 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
@@ -989,6 +989,7 @@ public class TsFileProcessor {
}
public WriteLogNode getLogNode() {
+ long start = System.nanoTime();
if (logNode == null) {
logNode =
MultiFileLogNodeManager.getInstance()
@@ -996,6 +997,10 @@ public class TsFileProcessor {
storageGroupName + "-" + tsFileResource.getTsFile().getName(),
storageGroupInfo.getWalSupplier());
}
+ long elapse = System.nanoTime() - start;
+ if (elapse > 3_000_000_000L) {
+ logger.warn("[WAL] {} getWalSupplier cost {}ms", this.hashCode(), elapse / 1_000_000L);
+ }
return logNode;
}
diff --git a/server/src/main/java/org/apache/iotdb/db/writelog/node/ExclusiveWriteLogNode.java b/server/src/main/java/org/apache/iotdb/db/writelog/node/ExclusiveWriteLogNode.java
index 9a1b68c..30c1213 100644
--- a/server/src/main/java/org/apache/iotdb/db/writelog/node/ExclusiveWriteLogNode.java
+++ b/server/src/main/java/org/apache/iotdb/db/writelog/node/ExclusiveWriteLogNode.java
@@ -233,8 +233,7 @@ public class ExclusiveWriteLogNode implements WriteLogNode, Comparable<Exclusive
lock.unlock();
long elapse = System.nanoTime() - start;
if (elapse > 3_000_000_000L) {
- logger.warn(
- "[WAL] {} flushBuffer write log cost {}ms", this.hashCode(), elapse / 1_000_000L);
+ logger.warn("[WAL] {} delete logNode cost {}ms", this.hashCode(), elapse / 1_000_000L);
}
}
}