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

yuyuankang pushed a commit to branch cluster_performance
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git


The following commit(s) were added to refs/heads/cluster_performance by this 
push:
     new 3549404  test network
3549404 is described below

commit 354940413da52ffcdddf246b175f31943085716b
Author: Ring-k <[email protected]>
AuthorDate: Wed Sep 2 10:19:40 2020 +0800

    test network
---
 .../main/java/org/apache/iotdb/cluster/server/member/RaftMember.java  | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/cluster/src/main/java/org/apache/iotdb/cluster/server/member/RaftMember.java 
b/cluster/src/main/java/org/apache/iotdb/cluster/server/member/RaftMember.java
index 7266e3d..d43e890 100644
--- 
a/cluster/src/main/java/org/apache/iotdb/cluster/server/member/RaftMember.java
+++ 
b/cluster/src/main/java/org/apache/iotdb/cluster/server/member/RaftMember.java
@@ -68,6 +68,7 @@ import org.apache.iotdb.cluster.log.HardState;
 import org.apache.iotdb.cluster.log.Log;
 import org.apache.iotdb.cluster.log.LogParser;
 import org.apache.iotdb.cluster.log.catchup.CatchUpTask;
+import org.apache.iotdb.cluster.log.logtypes.EmptyContentLog;
 import org.apache.iotdb.cluster.log.logtypes.PhysicalPlanLog;
 import org.apache.iotdb.cluster.log.manage.RaftLogManager;
 import org.apache.iotdb.cluster.rpc.thrift.AppendEntriesRequest;
@@ -491,7 +492,8 @@ public abstract class RaftMember {
       return checkResult;
     }
 
-    Log log = LogParser.getINSTANCE().parse(request.entry);
+//    Log log = LogParser.getINSTANCE().parse(request.entry);
+    Log log = new EmptyContentLog(request.prevLogIndex + 1, 
request.prevLogTerm);
     long result = appendEntry(request.prevLogIndex, request.prevLogTerm, 
request.leaderCommit,
         log);
     logger.debug("{} AppendEntryRequest of {} completed", name, log);

Reply via email to