You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ta...@apache.org on 2023/03/10 11:28:45 UTC
[iotdb] branch rel/1.1 updated: Compatible with the client parameters on DataNode (#9272) (#9288)
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 5fb62e7505 Compatible with the client parameters on DataNode (#9272) (#9288)
5fb62e7505 is described below
commit 5fb62e75056c9a3be1bab133d8946688a64dc4b7
Author: YongzaoDan <33...@users.noreply.github.com>
AuthorDate: Fri Mar 10 19:28:37 2023 +0800
Compatible with the client parameters on DataNode (#9272) (#9288)
---
.../java/org/apache/iotdb/db/conf/IoTDBDescriptor.java | 18 ++++++++++++++++++
1 file changed, 18 insertions(+)
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..5efca9f11d 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,6 +229,14 @@ 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) {
+ conf.setCoreClientNumForEachNode(
+ Integer.parseInt(
+ properties.getProperty("dn_core_connection_for_internal_service").trim()));
+ 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.");
+ }
conf.setCoreClientNumForEachNode(
Integer.parseInt(
properties
@@ -237,6 +245,16 @@ public class IoTDBDescriptor {
String.valueOf(conf.getCoreClientNumForEachNode()))
.trim()));
+ if (properties.getProperty("dn_max_client_count_for_each_node_in_client_manager", null)
+ != null) {
+ conf.setMaxClientNumForEachNode(
+ Integer.parseInt(
+ properties
+ .getProperty("dn_max_client_count_for_each_node_in_client_manager")
+ .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.");
+ }
conf.setMaxClientNumForEachNode(
Integer.parseInt(
properties