fix-alibaba#2810.modify the judge logic when send beat in raftcore

horizonzy · May 15, 2020 · d72d059 · d72d059
1 parent 4baaef4
commit d72d059
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/naming/src/main/java/com/alibaba/nacos/naming/consistency/persistent/raft/RaftCore.java b/naming/src/main/java/com/alibaba/nacos/naming/consistency/persistent/raft/RaftCore.java
@@ -481,7 +481,10 @@ public void run() {
 
  public void sendBeat() throws IOException, InterruptedException {
  RaftPeer local = peers.local();
- if (local.state != RaftPeer.State.LEADER && !STANDALONE_MODE) {
+ if (STANDALONE_MODE){
+ return;
+ }
+ if (local.state != RaftPeer.State.LEADER) {
  return;
  }