You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by qi...@apache.org on 2021/07/28 09:28:16 UTC
[iotdb] branch autoai_debug updated: fix shutdown
This is an automated email from the ASF dual-hosted git repository.
qiaojialin 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 d4c3747 fix shutdown
d4c3747 is described below
commit d4c37471248b7797383604032e787e0edd498e38
Author: qiaojialin <64...@qq.com>
AuthorDate: Wed Jul 28 17:27:38 2021 +0800
fix shutdown
---
.../java/org/apache/iotdb/db/writelog/node/ExclusiveWriteLogNode.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 31b9265..9a1b68c 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
@@ -161,7 +161,6 @@ public class ExclusiveWriteLogNode implements WriteLogNode, Comparable<Exclusive
logger.warn("Waiting for current buffer being flushed interrupted");
} finally {
lock.unlock();
- FLUSH_BUFFER_THREAD_POOL.shutdown();
}
long elapse = System.nanoTime() - start;
if (elapse > 3_000_000_000L) {
@@ -230,6 +229,7 @@ public class ExclusiveWriteLogNode implements WriteLogNode, Comparable<Exclusive
deleted.set(true);
return this.bufferArray;
} finally {
+ FLUSH_BUFFER_THREAD_POOL.shutdown();
lock.unlock();
long elapse = System.nanoTime() - start;
if (elapse > 3_000_000_000L) {