You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ca...@apache.org on 2023/01/29 06:10:16 UTC
[iotdb] 01/01: add logWriter.close() for ConfigNodeRegionStateMachine
This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a commit to branch fix_simple_confignode_consensus
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 19833a7e54f0ab3322b0c4da3681616266e136e3
Author: Beyyes <cg...@foxmail.com>
AuthorDate: Sun Jan 29 14:10:01 2023 +0800
add logWriter.close() for ConfigNodeRegionStateMachine
---
.../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 74c5ed5784..db16cb9c83 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);