[iotdb] branch native_raft updated: fix unclosed file

[ji...@apache.org]

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

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


The following commit(s) were added to refs/heads/native_raft by this push:
     new 0b53e5812d fix unclosed file
0b53e5812d is described below

commit 0b53e5812d78e3e8076ede3867a0b413130049ce
Author: Tian Jiang <jt...@163.com>
AuthorDate: Fri Feb 17 15:22:28 2023 +0800

    fix unclosed file
---
 .../src/main/java/org/apache/iotdb/consensus/natraft/RaftConsensus.java  | 1 +
 1 file changed, 1 insertion(+)

diff --git a/consensus/src/main/java/org/apache/iotdb/consensus/natraft/RaftConsensus.java b/consensus/src/main/java/org/apache/iotdb/consensus/natraft/RaftConsensus.java
index 4df703ac6b..4e4674152e 100644
--- a/consensus/src/main/java/org/apache/iotdb/consensus/natraft/RaftConsensus.java
+++ b/consensus/src/main/java/org/apache/iotdb/consensus/natraft/RaftConsensus.java
@@ -140,6 +140,7 @@ public class RaftConsensus implements IConsensus {
     clientManager.close();
     stateMachineMap.values().parallelStream().forEach(RaftMember::stop);
     registerManager.deregisterAll();
+    FlowMonitorManager.INSTANCE.close();
   }
 
   @Override