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);