(iotdb) branch master updated: Pipe: Comment Config Check (#16194)

[justinchen]

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

justinchen 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 cdb35992f2f Pipe: Comment Config Check (#16194)
cdb35992f2f is described below

commit cdb35992f2f393f44d19ec6c167cbe4553b6214a
Author: Zhenyu Luo <zhe...@apache.org>
AuthorDate: Mon Aug 18 14:14:17 2025 +0800

    Pipe: Comment Config Check (#16194)
---
 .../apache/iotdb/commons/conf/CommonConfig.java    | 24 ++++++++++++++++++++++
 1 file changed, 24 insertions(+)

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 07b62adc504..1d02fbf1ec7 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
@@ -1147,6 +1147,12 @@ public class CommonConfig {
   }
 
   public void setPipeAsyncConnectorSelectorNumber(int 
pipeAsyncConnectorSelectorNumber) {
+    if (pipeAsyncConnectorSelectorNumber <= 0) {
+      logger.info(
+          "pipeAsyncConnectorSelectorNumber should be greater than 0, 
configuring it not to change.");
+      return;
+    }
+    pipeAsyncConnectorSelectorNumber = Math.max(4, 
pipeAsyncConnectorSelectorNumber);
     if (this.pipeAsyncConnectorSelectorNumber == 
pipeAsyncConnectorSelectorNumber) {
       return;
     }
@@ -1159,6 +1165,12 @@ public class CommonConfig {
   }
 
   public void setPipeAsyncConnectorMaxClientNumber(int 
pipeAsyncConnectorMaxClientNumber) {
+    if (pipeAsyncConnectorMaxClientNumber <= 0) {
+      logger.info(
+          " pipeAsyncConnectorMaxClientNumber should be greater than 0, 
configuring it not to change.");
+      return;
+    }
+    pipeAsyncConnectorMaxClientNumber = Math.max(32, 
pipeAsyncConnectorMaxClientNumber);
     if (this.pipeAsyncConnectorMaxClientNumber == 
pipeAsyncConnectorMaxClientNumber) {
       return;
     }
@@ -1173,6 +1185,12 @@ public class CommonConfig {
 
   public void setPipeAsyncConnectorMaxTsFileClientNumber(
       int pipeAsyncConnectorMaxTsFileClientNumber) {
+    if (pipeAsyncConnectorMaxTsFileClientNumber <= 0) {
+      logger.info(
+          "pipeAsyncConnectorMaxTsFileClientNumber should be greater than 0, 
configuring it not to change.");
+      return;
+    }
+    pipeAsyncConnectorMaxTsFileClientNumber = Math.max(16, 
pipeAsyncConnectorMaxTsFileClientNumber);
     if (this.pipeAsyncConnectorMaxTsFileClientNumber == 
pipeAsyncConnectorMaxTsFileClientNumber) {
       return;
     }
@@ -1317,6 +1335,12 @@ public class CommonConfig {
   }
 
   public void setPipeSubtaskExecutorMaxThreadNum(int 
pipeSubtaskExecutorMaxThreadNum) {
+    if (pipeSubtaskExecutorMaxThreadNum <= 0) {
+      logger.info(
+          "pipeSubtaskExecutorMaxThreadNum should be greater than 0, 
configuring it not to change.");
+      return;
+    }
+    pipeSubtaskExecutorMaxThreadNum = Math.max(5, 
pipeSubtaskExecutorMaxThreadNum);
     if (this.pipeSubtaskExecutorMaxThreadNum == 
pipeSubtaskExecutorMaxThreadNum) {
       return;
     }