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

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


The following commit(s) were added to refs/heads/multileader_restart_test by 
this push:
     new caac09cc45 fix the bug
caac09cc45 is described below

commit caac09cc458c75abae8141f36e8cad8a2fda7a23
Author: Jinrui.Zhang <[email protected]>
AuthorDate: Fri Jul 8 15:01:02 2022 +0800

    fix the bug
---
 .../consensus/multileader/service/MultiLeaderRPCServiceProcessor.java | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/consensus/src/main/java/org/apache/iotdb/consensus/multileader/service/MultiLeaderRPCServiceProcessor.java
 
b/consensus/src/main/java/org/apache/iotdb/consensus/multileader/service/MultiLeaderRPCServiceProcessor.java
index e9ef73d72b..97dd3ac525 100644
--- 
a/consensus/src/main/java/org/apache/iotdb/consensus/multileader/service/MultiLeaderRPCServiceProcessor.java
+++ 
b/consensus/src/main/java/org/apache/iotdb/consensus/multileader/service/MultiLeaderRPCServiceProcessor.java
@@ -30,6 +30,8 @@ import org.apache.thrift.async.AsyncMethodCallback;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import java.util.ArrayList;
+
 public class MultiLeaderRPCServiceProcessor implements 
MultiLeaderConsensusIService.AsyncIface {
 
   private final Logger logger = 
LoggerFactory.getLogger(MultiLeaderRPCServiceProcessor.class);
@@ -72,7 +74,7 @@ public class MultiLeaderRPCServiceProcessor implements 
MultiLeaderConsensusIServ
       //      }
       //      logger.debug("Execute TSyncLogReq for {} with result {}", 
req.consensusGroupId,
       // statuses);
-      resultHandler.onComplete(new TSyncLogRes());
+      resultHandler.onComplete(new TSyncLogRes(new ArrayList<>()));
     } catch (Exception e) {
       resultHandler.onError(e);
     } finally {

Reply via email to