[iotdb] branch clear_wal updated: remove all timer in wal

[qiaojialin]

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

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


The following commit(s) were added to refs/heads/clear_wal by this push:
     new 629358e  remove all timer in wal
629358e is described below

commit 629358ef845b181f601c5ed3fad280925b4349bb
Author: qiaojialin <646274...@qq.com>
AuthorDate: Wed Jul 21 18:44:56 2021 +0800

    remove all timer in wal
---
 .../apache/iotdb/db/writelog/node/ExclusiveWriteLogNode.java   | 10 ----------
 1 file changed, 10 deletions(-)

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 f2980a4..e982c77 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
@@ -273,7 +273,6 @@ public class ExclusiveWriteLogNode implements WriteLogNode, 
Comparable<Exclusive
   }
 
   private void flushBuffer(ILogWriter writer) {
-    long start = System.nanoTime();
     try {
       writer.write(logBufferFlushing);
     } catch (ClosedChannelException e) {
@@ -290,14 +289,9 @@ public class ExclusiveWriteLogNode implements 
WriteLogNode, Comparable<Exclusive
       logBufferFlushing = null;
       switchBufferCondition.notifyAll();
     }
-    long elapse = System.nanoTime() - start;
-    if (elapse > 3000000000L) {
-      logger.error("[wal] {} Flushing -> idle cost: {}ms", this.hashCode(), 
elapse / 1000000);
-    }
   }
 
   private void switchBufferWorkingToFlushing() throws InterruptedException {
-    long start = System.nanoTime();
     synchronized (switchBufferCondition) {
       while (logBufferFlushing != null && !deleted.get()) {
         switchBufferCondition.wait(100);
@@ -307,10 +301,6 @@ public class ExclusiveWriteLogNode implements 
WriteLogNode, Comparable<Exclusive
       logBufferWorking.clear();
       logBufferIdle = null;
     }
-    long elapse = System.nanoTime() - start;
-    if (elapse > 3000000000L) {
-      logger.error("[wal] {} Working -> Flushing cost: {}ms", this.hashCode(), 
elapse / 1000000);
-    }
   }
 
   private ILogWriter getCurrentFileWriter() throws FileNotFoundException {