You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xi...@apache.org on 2022/08/05 08:49:17 UTC
[iotdb] branch ml_0729_test_exp1_no_write updated: enable write in follower
This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a commit to branch ml_0729_test_exp1_no_write
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/ml_0729_test_exp1_no_write by this push:
new 7e35c72ee0 enable write in follower
7e35c72ee0 is described below
commit 7e35c72ee098747e8d4c4f399ea8bbc39fef210b
Author: Jinrui.Zhang <xi...@gmail.com>
AuthorDate: Fri Aug 5 16:49:04 2022 +0800
enable write in follower
---
.../iotdb/db/consensus/statemachine/DataRegionStateMachine.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/consensus/statemachine/DataRegionStateMachine.java b/server/src/main/java/org/apache/iotdb/db/consensus/statemachine/DataRegionStateMachine.java
index 7342976f4a..8c63bcf173 100644
--- a/server/src/main/java/org/apache/iotdb/db/consensus/statemachine/DataRegionStateMachine.java
+++ b/server/src/main/java/org/apache/iotdb/db/consensus/statemachine/DataRegionStateMachine.java
@@ -185,9 +185,9 @@ public class DataRegionStateMachine extends BaseStateMachine {
StepTracker.trace("followerWritePrepare", 25, prepareStartTime, System.nanoTime());
long writeStartTime = System.nanoTime();
if (insertNodeWrapper != null) {
- // for (InsertNode insertNode : insertNodeWrapper.getInsertNodes()) {
- // statuses.add(write(insertNode));
- // }
+ for (InsertNode insertNode : insertNodeWrapper.getInsertNodes()) {
+ statuses.add(write(insertNode));
+ }
insertNodeWrapper.resultHandler.onComplete(new TSyncLogRes(statuses));
}
StepTracker.trace("followerWriteInsert", 25, writeStartTime, System.nanoTime());