[iotdb] branch ml_0729_test_exp1 updated: change min processor count to 16

[xingtanzjr]

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

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


The following commit(s) were added to refs/heads/ml_0729_test_exp1 by this push:
     new 7b39bcefff change min processor count to 16
7b39bcefff is described below

commit 7b39bcefffb5f5bd8b5ecf8b49e443ed6dd629bf
Author: Jinrui.Zhang <xingtan...@gmail.com>
AuthorDate: Tue Aug 2 15:05:30 2022 +0800

    change min processor count to 16
---
 .../main/java/org/apache/iotdb/consensus/config/MultiLeaderConfig.java  | 2 +-
 server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java          | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/consensus/src/main/java/org/apache/iotdb/consensus/config/MultiLeaderConfig.java
 
b/consensus/src/main/java/org/apache/iotdb/consensus/config/MultiLeaderConfig.java
index 9d4665e4d4..1a9b4dac9f 100644
--- 
a/consensus/src/main/java/org/apache/iotdb/consensus/config/MultiLeaderConfig.java
+++ 
b/consensus/src/main/java/org/apache/iotdb/consensus/config/MultiLeaderConfig.java
@@ -132,7 +132,7 @@ public class MultiLeaderConfig {
 
     public static class Builder {
       private int rpcSelectorThreadNum = 1;
-      private int rpcMinConcurrentClientNum = 
Runtime.getRuntime().availableProcessors();
+      private int rpcMinConcurrentClientNum = 16;
       private int rpcMaxConcurrentClientNum = 65535;
       private int thriftServerAwaitTimeForStopService = 60;
       private boolean isRpcThriftCompressionEnabled = false;
diff --git a/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java 
b/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
index 3df27bacd3..0f3ed34104 100644
--- a/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
+++ b/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
@@ -118,7 +118,7 @@ public class IoTDBConfig {
   private int rpcSelectorThreadNum = 1;
 
   /** Min concurrent client number */
-  private int rpcMinConcurrentClientNum = 
Runtime.getRuntime().availableProcessors();
+  private int rpcMinConcurrentClientNum = 16;
 
   /** Max concurrent client number */
   private int rpcMaxConcurrentClientNum = 65535;