You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by yo...@apache.org on 2023/03/22 15:02:32 UTC
[iotdb] branch Compatible-with-the-client-parameters-on-DataNode created (now aca6db5826)
This is an automated email from the ASF dual-hosted git repository.
yongzao pushed a change to branch Compatible-with-the-client-parameters-on-DataNode
in repository https://gitbox.apache.org/repos/asf/iotdb.git
at aca6db5826 Update IoTDBDescriptor.java
This branch includes the following new commits:
new aca6db5826 Update IoTDBDescriptor.java
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[iotdb] 01/01: Update IoTDBDescriptor.java
Posted by yo...@apache.org.
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
commit aca6db582649435918352355c7d4184b6d9bae90
Author: YongzaoDan <53...@qq.com>
AuthorDate: Wed Mar 22 23:02:22 2023 +0800
Update IoTDBDescriptor.java
---
.../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 26e0544248..b6961fab44 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(