This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch fix-pipe-cause-wal-pin in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit cbbb29152f5e1a123daa5822784f51730fd7089e Author: Steve Yurong Su <[email protected]> AuthorDate: Thu Sep 28 12:29:56 2023 +0800 config.setPipeSubtaskExecutorMaxThreadNum(10) --- .../node-commons/src/assembly/resources/conf/iotdb-common.properties | 2 +- .../src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java | 2 +- .../src/main/java/org/apache/iotdb/commons/conf/CommonDescriptor.java | 2 +- 3 files changed, 3 insertions(+), 3 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 cff20c83ffb..59c0db98e56 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 @@ -938,7 +938,7 @@ timestamp_precision=ms # The maximum number of threads that can be used to execute the pipe subtasks in PipeSubtaskExecutor. # The actual value will be min(pipe_subtask_executor_max_thread_num, max(1, CPU core number / 2)). -# pipe_subtask_executor_max_thread_num=5 +# pipe_subtask_executor_max_thread_num=10 # The connection timeout (in milliseconds) for the thrift client. # pipe_connector_timeout_ms=900000 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 1bc039f2d54..4ba4b8af519 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 @@ -156,7 +156,7 @@ public class CommonConfig { /** The maximum number of threads that can be used to execute subtasks in PipeSubtaskExecutor. */ private int pipeSubtaskExecutorMaxThreadNum = - Math.min(5, Math.max(1, Runtime.getRuntime().availableProcessors() / 2)); + Math.min(10, Math.max(1, Runtime.getRuntime().availableProcessors() / 2)); private int pipeSubtaskExecutorBasicCheckPointIntervalByConsumedEventCount = 10_000; private long pipeSubtaskExecutorBasicCheckPointIntervalByTimeDuration = 10 * 1000L; diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonDescriptor.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonDescriptor.java index 6177623fead..6cd8420a5c1 100644 --- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonDescriptor.java +++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonDescriptor.java @@ -281,7 +281,7 @@ public class CommonDescriptor { "pipe_subtask_executor_max_thread_num", Integer.toString(config.getPipeSubtaskExecutorMaxThreadNum())))); if (config.getPipeSubtaskExecutorMaxThreadNum() <= 0) { - config.setPipeSubtaskExecutorMaxThreadNum(5); + config.setPipeSubtaskExecutorMaxThreadNum(10); } config.setPipeSubtaskExecutorBasicCheckPointIntervalByConsumedEventCount( Integer.parseInt(
