[iotdb] branch beyyes/rel_1.0/confignode_simple updated: add close method

[ca...@apache.org]

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

caogaofei pushed a commit to branch beyyes/rel_1.0/confignode_simple
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/beyyes/rel_1.0/confignode_simple by this push:
     new f19bc022d1 add close method
f19bc022d1 is described below

commit f19bc022d1c3d9aa0c24eea528575523bda699bd
Author: Beyyes <cg...@foxmail.com>
AuthorDate: Sun Jan 29 20:24:05 2023 +0800

    add close method
---
 .../confignode/consensus/statemachine/ConfigNodeRegionStateMachine.java  | 1 +
 1 file changed, 1 insertion(+)

diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/statemachine/ConfigNodeRegionStateMachine.java b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/statemachine/ConfigNodeRegionStateMachine.java
index 70e28bbf6d..49136728e4 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/statemachine/ConfigNodeRegionStateMachine.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/statemachine/ConfigNodeRegionStateMachine.java
@@ -297,6 +297,7 @@ public class ConfigNodeRegionStateMachine
       // The method logWriter.write will execute flip() firstly, so we must make position==limit
       buffer.position(buffer.limit());
       logWriter.write(buffer);
+      logWriter.close();
       endIndex = endIndex + 1;
       File tmpLogFile = new File(PROGRESS_FILE_PATH + endIndex);
       Files.move(logFile.toPath(), tmpLogFile.toPath(), StandardCopyOption.ATOMIC_MOVE);