[iotdb] branch Compatible-with-the-client-parameters-on-DataNode updated: Finish

[yongzao]

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

yongzao pushed a commit to branch 
Compatible-with-the-client-parameters-on-DataNode
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to 
refs/heads/Compatible-with-the-client-parameters-on-DataNode by this push:
     new 91632a2fc2 Finish
91632a2fc2 is described below

commit 91632a2fc2df375a9684508c4286a27226e7465c
Author: YongzaoDan <532741...@qq.com>
AuthorDate: Thu Mar 9 21:52:06 2023 +0800

    Finish
---
 .../org/apache/iotdb/db/conf/IoTDBDescriptor.java  | 30 +++++++++++++++++-----
 1 file changed, 23 insertions(+), 7 deletions(-)

diff --git a/server/src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java 
b/server/src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java
index 0432754ab7..af01f02ec1 100644
--- a/server/src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java
+++ b/server/src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java
@@ -229,13 +229,29 @@ public class IoTDBDescriptor {
                     "dn_connection_timeout_ms", 
String.valueOf(conf.getConnectionTimeoutInMS()))
                 .trim()));
 
-    conf.setCoreClientNumForEachNode(
-        Integer.parseInt(
-            properties
-                .getProperty(
-                    "dn_core_client_count_for_each_node_in_client_manager",
-                    String.valueOf(conf.getCoreClientNumForEachNode()))
-                .trim()));
+    String dnCoreClientCount =
+        
properties.getProperty("dn_core_client_count_for_each_node_in_client_manager", 
null);
+    if (dnCoreClientCount == null) {
+      // For compatible
+      dnCoreClientCount = 
properties.getProperty("dn_core_connection_for_internal_service", null);
+      logger.warn(
+          "The parameter dn_core_connection_for_internal_service is out of 
date. Please rename it to 
dn_core_client_count_for_each_node_in_client_manager.");
+    }
+    if (dnCoreClientCount != null) {
+      conf.setCoreClientNumForEachNode(Integer.parseInt(dnCoreClientCount));
+    }
+
+    String dnMaxClientCount =
+        
properties.getProperty("dn_max_client_count_for_each_node_in_client_manager", 
null);
+    if (dnMaxClientCount == null) {
+      // For compatible
+      dnMaxClientCount = 
properties.getProperty("dn_max_connection_for_internal_service", null);
+      logger.warn(
+          "The parameter dn_max_connection_for_internal_service is out of 
date. Please rename it to 
dn_max_client_count_for_each_node_in_client_manager.");
+    }
+    if (dnMaxClientCount != null) {
+      conf.setMaxClientNumForEachNode(Integer.parseInt(dnMaxClientCount));
+    }
 
     conf.setMaxClientNumForEachNode(
         Integer.parseInt(