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 <[email protected]> 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
