This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a commit to branch rel/1.1
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/rel/1.1 by this push:
new 5f036a98ef Compatible with the client parameters on DataNode (#9421)
5f036a98ef is described below
commit 5f036a98efe43ea1de150dbf7785dbe3cba53828
Author: YongzaoDan <[email protected]>
AuthorDate: Wed Mar 22 23:17:53 2023 +0800
Compatible with the client parameters on DataNode (#9421)
---
.../main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java | 12 ++++--------
1 file changed, 4 insertions(+), 8 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 29a9caf080..77378e7f72 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,8 +229,7 @@ public class IoTDBDescriptor {
"dn_connection_timeout_ms",
String.valueOf(conf.getConnectionTimeoutInMS()))
.trim()));
- if
(properties.getProperty("dn_core_client_count_for_each_node_in_client_manager",
null)
- != null) {
+ if (properties.getProperty("dn_core_connection_for_internal_service",
null) != null) {
conf.setCoreClientNumForEachNode(
Integer.parseInt(
properties.getProperty("dn_core_connection_for_internal_service").trim()));
@@ -245,15 +244,12 @@ public class IoTDBDescriptor {
String.valueOf(conf.getCoreClientNumForEachNode()))
.trim()));
- if
(properties.getProperty("dn_max_client_count_for_each_node_in_client_manager",
null)
- != null) {
+ if (properties.getProperty("dn_max_connection_for_internal_service", null)
!= null) {
conf.setMaxClientNumForEachNode(
Integer.parseInt(
- properties
-
.getProperty("dn_max_client_count_for_each_node_in_client_manager")
- .trim()));
+
properties.getProperty("dn_max_connection_for_internal_service").trim()));
logger.warn(
- "The parameter dn_max_client_count_for_each_node_in_client_manager
is out of date. Please rename it to
dn_max_client_count_for_each_node_in_client_manager.");
+ "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.");
}
conf.setMaxClientNumForEachNode(
Integer.parseInt(
