[incubator-iotdb] branch cluster_performance updated: election

[yuyuankang]

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 79c75e7  election
79c75e7 is described below

commit 79c75e79e58046c3504779c6374279396f233a51
Author: Ring-k <yuyuank...@hotmail.com>
AuthorDate: Mon Sep 7 09:16:50 2020 +0800

    election
---
 .../apache/iotdb/cluster/server/heartbeat/DataHeartbeatThread.java | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git 
a/cluster/src/main/java/org/apache/iotdb/cluster/server/heartbeat/DataHeartbeatThread.java
 
b/cluster/src/main/java/org/apache/iotdb/cluster/server/heartbeat/DataHeartbeatThread.java
index 1898b9e..24cd5cb 100644
--- 
a/cluster/src/main/java/org/apache/iotdb/cluster/server/heartbeat/DataHeartbeatThread.java
+++ 
b/cluster/src/main/java/org/apache/iotdb/cluster/server/heartbeat/DataHeartbeatThread.java
@@ -25,6 +25,7 @@ import org.apache.iotdb.cluster.server.member.DataGroupMember;
 public class DataHeartbeatThread extends HeartbeatThread {
 
   private DataGroupMember dataGroupMember;
+  int number = 1;
 
   public DataHeartbeatThread(DataGroupMember raftMember) {
     super(raftMember);
@@ -55,6 +56,12 @@ public class DataHeartbeatThread extends HeartbeatThread {
     
electionRequest.setLastLogIndex(dataGroupMember.getMetaGroupMember().getLogManager().getLastLogIndex());
     
electionRequest.setDataLogLastIndex(dataGroupMember.getLogManager().getLastLogIndex());
     
electionRequest.setDataLogLastTerm(dataGroupMember.getLogManager().getLastLogTerm());
+    if(dataGroupMember.getThisNode() != dataGroupMember.getHeader()){
+      if(number%4 != 0){
+        number++;
+        return;
+      }
+    }
     super.startElection();
   }
 }