[iotdb] branch ml_0729_test_exp1_no_write updated: enable write in leader

[xingtanzjr]

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 59ba5a2ff2 enable write in leader
59ba5a2ff2 is described below

commit 59ba5a2ff21b95674f2ad7144af4c7e7f83c175a
Author: Jinrui.Zhang <xingtan...@gmail.com>
AuthorDate: Fri Aug 5 16:32:55 2022 +0800

    enable write in leader
---
 .../apache/iotdb/consensus/multileader/MultiLeaderServerImpl.java   | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/consensus/src/main/java/org/apache/iotdb/consensus/multileader/MultiLeaderServerImpl.java
 
b/consensus/src/main/java/org/apache/iotdb/consensus/multileader/MultiLeaderServerImpl.java
index 973a31272d..fca6971b3d 100644
--- 
a/consensus/src/main/java/org/apache/iotdb/consensus/multileader/MultiLeaderServerImpl.java
+++ 
b/consensus/src/main/java/org/apache/iotdb/consensus/multileader/MultiLeaderServerImpl.java
@@ -125,8 +125,8 @@ public class MultiLeaderServerImpl {
               indexedConsensusRequest.getSearchIndex());
         }
         // TODO wal and memtable
-        //        TSStatus result = 
stateMachine.write(indexedConsensusRequest);
-        TSStatus result = new 
TSStatus(TSStatusCode.SUCCESS_STATUS.getStatusCode());
+        TSStatus result = stateMachine.write(indexedConsensusRequest);
+//        TSStatus result = new 
TSStatus(TSStatusCode.SUCCESS_STATUS.getStatusCode());
         StepTracker.trace("stateMachineWrite", startTimeAfterLock, 
System.nanoTime());
         long offerStartTime = System.nanoTime();
         if (result.getCode() == TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
@@ -162,7 +162,7 @@ public class MultiLeaderServerImpl {
 
   public void persistConfiguration() {
     try (PublicBAOS publicBAOS = new PublicBAOS();
-        DataOutputStream outputStream = new DataOutputStream(publicBAOS)) {
+         DataOutputStream outputStream = new DataOutputStream(publicBAOS)) {
       outputStream.writeInt(configuration.size());
       for (Peer peer : configuration) {
         peer.serialize(outputStream);