[iotdb] branch expr_vgraft updated: can disable recalculateMap in IndirectLogDispatcher

[ji...@apache.org]

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

jiangtian pushed a commit to branch expr_vgraft
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/expr_vgraft by this push:
     new 8244f43369 can disable recalculateMap in IndirectLogDispatcher
8244f43369 is described below

commit 8244f4336940f43a717f3cee0546b034e56b8121
Author: Tian Jiang <jt...@163.com>
AuthorDate: Wed Oct 5 10:09:09 2022 +0800

    can disable recalculateMap in IndirectLogDispatcher
---
 .../main/java/org/apache/iotdb/cluster/log/IndirectLogDispatcher.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/log/IndirectLogDispatcher.java b/cluster/src/main/java/org/apache/iotdb/cluster/log/IndirectLogDispatcher.java
index 0f99bb9fe7..56b4cf2a50 100644
--- a/cluster/src/main/java/org/apache/iotdb/cluster/log/IndirectLogDispatcher.java
+++ b/cluster/src/main/java/org/apache/iotdb/cluster/log/IndirectLogDispatcher.java
@@ -56,7 +56,7 @@ public class IndirectLogDispatcher extends LogDispatcher {
 
   private Map<Node, List<Node>> directToIndirectFollowerMap = new ConcurrentHashMap<>();
   private long dispatchedEntryNum;
-  private int recalculateMapInterval = 1;
+  private int recalculateMapInterval = -1;
   private Random random = new Random();
 
   public IndirectLogDispatcher(RaftMember member) {
@@ -105,7 +105,7 @@ public class IndirectLogDispatcher extends LogDispatcher {
   public void offer(SendLogRequest request) {
     super.offer(request);
     dispatchedEntryNum++;
-    if (dispatchedEntryNum % recalculateMapInterval == 0) {
+    if (recalculateMapInterval > 0 && dispatchedEntryNum % recalculateMapInterval == 0) {
       recalculateDirectFollowerMap();
     }
   }