You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ro...@apache.org on 2021/08/17 07:26:20 UTC

[iotdb] branch shutdown-FLUSH_BUFFER_THREAD_POOL created (now 37d6ec2)

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

rong pushed a change to branch shutdown-FLUSH_BUFFER_THREAD_POOL
in repository https://gitbox.apache.org/repos/asf/iotdb.git.


      at 37d6ec2  shutdown FLUSH_BUFFER_THREAD_POOL (#3643)

This branch includes the following new commits:

     new 37d6ec2  shutdown FLUSH_BUFFER_THREAD_POOL (#3643)

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


[iotdb] 01/01: shutdown FLUSH_BUFFER_THREAD_POOL (#3643)

Posted by ro...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

rong pushed a commit to branch shutdown-FLUSH_BUFFER_THREAD_POOL
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit 37d6ec278c2144d9a162dfc25dfe3a959f2e7771
Author: Jialin Qiao <qj...@mails.tsinghua.edu.cn>
AuthorDate: Wed Jul 28 04:59:47 2021 -0500

    shutdown FLUSH_BUFFER_THREAD_POOL (#3643)
---
 .../java/org/apache/iotdb/db/writelog/node/ExclusiveWriteLogNode.java    | 1 +
 1 file changed, 1 insertion(+)

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 c947963..99a14b0 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
@@ -211,6 +211,7 @@ public class ExclusiveWriteLogNode implements WriteLogNode, Comparable<Exclusive
       deleted = true;
       return this.bufferArray;
     } finally {
+      FLUSH_BUFFER_THREAD_POOL.shutdown();
       lock.unlock();
     }
   }