[iotdb] branch beyyes/confignode_develop updated: using only one genHeartbeatReq for pingDataNodes

[ca...@apache.org]

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

caogaofei pushed a commit to branch beyyes/confignode_develop
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/beyyes/confignode_develop by this push:
     new b806fe4bfc using only one genHeartbeatReq for pingDataNodes
b806fe4bfc is described below

commit b806fe4bfcbce56f11bc513e42b78e7315c6f5ce
Author: Beyyes <cg...@foxmail.com>
AuthorDate: Tue Aug 2 16:09:04 2022 +0800

    using only one genHeartbeatReq for pingDataNodes
---
 .../java/org/apache/iotdb/confignode/manager/load/LoadManager.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/LoadManager.java b/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/LoadManager.java
index c998ee43b1..aac9da0bc6 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/LoadManager.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/LoadManager.java
@@ -340,7 +340,7 @@ public class LoadManager {
    */
   private void pingRegisteredDataNodes(List<TDataNodeConfiguration> registeredDataNodes) {
     // Generate heartbeat request
-    // THeartbeatReq heartbeatReq = genHeartbeatReq();
+    THeartbeatReq heartbeatReq = genHeartbeatReq();
 
     // Send heartbeat requests
     for (TDataNodeConfiguration dataNodeInfo : registeredDataNodes) {
@@ -355,7 +355,7 @@ public class LoadManager {
 
       AsyncDataNodeClientPool.getInstance()
           .getDataNodeHeartBeat(
-              dataNodeInfo.getLocation().getInternalEndPoint(), genHeartbeatReq(), handler);
+              dataNodeInfo.getLocation().getInternalEndPoint(), heartbeatReq, handler);
     }
   }