(iotdb) branch dev/1.3 updated: [To dev/1.3] Pipe: Comment Config Check (#16194) (#16208)

[justinchen]

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

justinchen pushed a commit to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/dev/1.3 by this push:
     new 45923686665 [To dev/1.3] Pipe: Comment Config Check (#16194) (#16208)
45923686665 is described below

commit 459236866659decb4d9e0cde4bf3210654ceb99b
Author: Zhenyu Luo <zhe...@apache.org>
AuthorDate: Tue Aug 19 17:10:13 2025 +0800

    [To dev/1.3] Pipe: Comment Config Check (#16194) (#16208)
    
    (cherry picked from commit cdb35992f2f393f44d19ec6c167cbe4553b6214a)
---
 .../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 5bb1d5234e6..a97599fac74 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
@@ -1154,6 +1154,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;
     }
@@ -1166,6 +1172,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;
     }
@@ -1180,6 +1192,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;
     }
@@ -1324,6 +1342,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;
     }