(iotdb) branch master updated: Set ConfigNode list early during DataNode registration (#12137)

[tanxinyu]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new cda79b4b026 Set ConfigNode list early during DataNode registration  
(#12137)
cda79b4b026 is described below

commit cda79b4b026d9dfc32eef5d871b72246589fce9e
Author: Li Yu Heng <liyuheng55...@126.com>
AuthorDate: Fri Mar 8 11:52:28 2024 +0800

    Set ConfigNode list early during DataNode registration  (#12137)
---
 .../java/org/apache/iotdb/confignode/manager/node/NodeManager.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/node/NodeManager.java
 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/node/NodeManager.java
index 62b7189c62d..7eac6c23c5f 100644
--- 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/node/NodeManager.java
+++ 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/node/NodeManager.java
@@ -258,6 +258,7 @@ public class NodeManager {
    */
   public DataSet registerDataNode(TDataNodeRegisterReq req) {
     DataNodeRegisterResp resp = new DataNodeRegisterResp();
+    resp.setConfigNodeList(getRegisteredConfigNodes());
     final String clusterId =
         configManager
             .getClusterManager()
@@ -266,7 +267,7 @@ public class NodeManager {
     if (clusterId == null) {
       resp.setStatus(
           new TSStatus(TSStatusCode.GET_CLUSTER_ID_ERROR.getStatusCode())
-              .setMessage("clusterId has not generated"));
+              .setMessage("clusterId has not generated, please try again 
later"));
       return resp;
     }
 
@@ -305,7 +306,6 @@ public class NodeManager {
     getClusterSchemaManager().adjustMaxRegionGroupNum();
 
     resp.setStatus(ClusterNodeStartUtils.ACCEPT_NODE_REGISTRATION);
-    resp.setConfigNodeList(getRegisteredConfigNodes());
     resp.setDataNodeId(
         
registerDataNodePlan.getDataNodeConfiguration().getLocation().getDataNodeId());
     
resp.setRuntimeConfiguration(getRuntimeConfiguration().setClusterId(clusterId));