This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch dec-pipe-selector in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 941560e91a8b0ecd885e1f41d6b73cda1f6f95ea Author: Steve Yurong Su <[email protected]> AuthorDate: Mon Jan 22 10:10:48 2024 +0800 Pipe: decrease the default value of pipe_sink_selector_number to 4 for better performance --- .../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;
