(iotdb) branch master updated: Reduce default value of rpcMaxConcurrentClientNum (#15260)

[tanxinyu]

This is an automated email from the ASF dual-hosted git repository.

tanxinyu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new d3d0687b3be Reduce default value of rpcMaxConcurrentClientNum (#15260)
d3d0687b3be is described below

commit d3d0687b3be9d0b91890369725718b00fbb81f24
Author: Haonan <hhao...@outlook.com>
AuthorDate: Wed Apr 2 17:42:01 2025 +0800

    Reduce default value of rpcMaxConcurrentClientNum (#15260)
---
 .../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 b6e7e71ea06..3e27d24b783 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
@@ -149,7 +149,7 @@ public class IoTDBConfig {
   private int rpcMinConcurrentClientNum = 
Runtime.getRuntime().availableProcessors();
 
   /** Max concurrent client number */
-  private int rpcMaxConcurrentClientNum = 65535;
+  private int rpcMaxConcurrentClientNum = 1000;
 
   private long allocateMemoryForRead = 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 7a10972ef08..c2d6f90e5ec 100755
--- 
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
@@ -746,7 +746,7 @@ public class IoTDBDescriptor {
                 "dn_rpc_max_concurrent_client_num",
                 Integer.toString(conf.getRpcMaxConcurrentClientNum())));
     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 4318cf128aa..2fa2c51e3d4 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
@@ -460,7 +460,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
@@ -510,7 +510,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