You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2025/09/01 09:04:34 UTC
(iotdb) 10/16: Reduce default value of rpcMaxConcurrentClientNum (#15260) (#15848)
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch rc/1.3.5
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 8729998da9812a17993c2decf24fd14379ec3071
Author: Haonan <hh...@outlook.com>
AuthorDate: Tue Jul 1 11:32:51 2025 +0800
Reduce default value of rpcMaxConcurrentClientNum (#15260) (#15848)
---
.../main/java/org/apache/iotdb/confignode/conf/ConfigNodeConfig.java | 2 +-
.../datanode/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java | 2 +-
.../src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java | 2 +-
.../src/assembly/resources/conf/iotdb-system.properties.template | 4 ++--
4 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConfig.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConfig.java
index 1a4c4f3e329..50c8f5bc9a0 100644
--- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConfig.java
+++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConfig.java
@@ -121,7 +121,7 @@ public class ConfigNodeConfig {
RegionBalancer.RegionGroupAllocatePolicy.GCR;
/** Max concurrent client number. */
- private int rpcMaxConcurrentClientNum = 65535;
+ private int rpcMaxConcurrentClientNum = 3000;
/** just for test wait for 60 second by default. */
private int thriftServerAwaitTimeForStopService = 60;
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
index d429afe529d..446a428eee7 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
@@ -145,7 +145,7 @@ public class IoTDBConfig {
private int rpcMinConcurrentClientNum = Runtime.getRuntime().availableProcessors();
/** Max concurrent client number */
- private int rpcMaxConcurrentClientNum = 65535;
+ private int rpcMaxConcurrentClientNum = 1000;
/** Memory allocated for the write process */
private long allocateMemoryForStorageEngine = Runtime.getRuntime().maxMemory() * 3 / 10;
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java
index 7daa0e726c3..25f3095d9a0 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java
@@ -801,7 +801,7 @@ public class IoTDBDescriptor {
"dn_rpc_max_concurrent_client_num",
Integer.toString(conf.getRpcMaxConcurrentClientNum()).trim()));
if (maxConcurrentClientNum <= 0) {
- maxConcurrentClientNum = 65535;
+ maxConcurrentClientNum = 1000;
}
conf.setRpcMaxConcurrentClientNum(maxConcurrentClientNum);
diff --git a/iotdb-core/node-commons/src/assembly/resources/conf/iotdb-system.properties.template b/iotdb-core/node-commons/src/assembly/resources/conf/iotdb-system.properties.template
index ac30871fdc3..c9b47d56ac3 100644
--- a/iotdb-core/node-commons/src/assembly/resources/conf/iotdb-system.properties.template
+++ b/iotdb-core/node-commons/src/assembly/resources/conf/iotdb-system.properties.template
@@ -457,7 +457,7 @@ cn_rpc_thrift_compression_enable=false
# The maximum number of concurrent clients that can be connected to the configNode.
# effectiveMode: restart
# Datatype: int
-cn_rpc_max_concurrent_client_num=65535
+cn_rpc_max_concurrent_client_num=3000
# Thrift socket and connection timeout between raft nodes, in milliseconds.
# effectiveMode: restart
@@ -507,7 +507,7 @@ dn_rpc_min_concurrent_client_num=1
# The maximum number of concurrent clients that can be connected to the dataNode.
# effectiveMode: restart
# Datatype: int
-dn_rpc_max_concurrent_client_num=65535
+dn_rpc_max_concurrent_client_num=1000
# thrift max frame size, 512MB by default
# effectiveMode: restart