Pipe: decrease the default value of pipe_sink_selector_number to 4 fo…

…r better performance (apache#11942)
Caideyipi · Jan 22, 2024 · f1db292 · f1db292
1 parent 4ec7956
commit f1db292
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 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
@@ -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
@@ -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;