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 {