(iotdb) branch master updated: Pipe: decrease the default value of pipe_sink_selector_number to 4 for better performance (#11942)

[rong]

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

rong 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 f1db2923dfb Pipe: decrease the default value of 
pipe_sink_selector_number to 4 for better performance (#11942)
f1db2923dfb is described below

commit f1db2923dfb9c0d2642bdc6c240883e9f4b06922
Author: Steve Yurong Su <r...@apache.org>
AuthorDate: Mon Jan 22 12:13:27 2024 +0800

    Pipe: decrease the default value of pipe_sink_selector_number to 4 for 
better performance (#11942)
---
 .../node-commons/src/assembly/resources/conf/iotdb-common.properties    | 2 +-
 .../src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java       | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/iotdb-core/node-commons/src/assembly/resources/conf/iotdb-common.properties 
b/iotdb-core/node-commons/src/assembly/resources/conf/iotdb-common.properties
index b70df894ee7..6d8d6782304 100644
--- 
a/iotdb-core/node-commons/src/assembly/resources/conf/iotdb-common.properties
+++ 
b/iotdb-core/node-commons/src/assembly/resources/conf/iotdb-common.properties
@@ -953,7 +953,7 @@ data_replication_factor=1
 
 # The maximum number of selectors that can be used in the sink.
 # Recommend to set this value to less than or equal to 
pipe_sink_max_client_number.
-# pipe_sink_selector_number=8
+# pipe_sink_selector_number=4
 
 # The core number of clients that can be used in the sink.
 # pipe_sink_core_client_number=8
diff --git 
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java
 
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java
index 525a0078272..4aacf87a386 100644
--- 
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java
+++ 
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java
@@ -171,7 +171,7 @@ public class CommonConfig {
   private int pipeConnectorPendingQueueSize = 256;
   private boolean pipeConnectorRPCThriftCompressionEnabled = false;
 
-  private int pipeAsyncConnectorSelectorNumber = 8;
+  private int pipeAsyncConnectorSelectorNumber = 4;
   private int pipeAsyncConnectorCoreClientNumber = 8;
   private int pipeAsyncConnectorMaxClientNumber = 16;