(iotdb) branch dev/1.3 updated: Disabled the repeatable pipe log when the receiver is down (#16963) (#16974)

[jiangtian]

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

jiangtian 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 b48b46e61b1 Disabled the repeatable pipe log when the receiver is down 
 (#16963) (#16974)
b48b46e61b1 is described below

commit b48b46e61b17a3c60f8dde98cdf7317486536fa7
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Wed Dec 31 14:13:14 2025 +0800

    Disabled the repeatable pipe log when the receiver is down  (#16963) 
(#16974)
---
 .../org/apache/iotdb/commons/client/ClientPoolFactory.java  |  1 +
 .../java/org/apache/iotdb/commons/conf/CommonConfig.java    | 13 +++++++++++++
 .../apache/iotdb/commons/pipe/config/PipeDescriptor.java    |  5 +++++
 3 files changed, 19 insertions(+)

diff --git 
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/ClientPoolFactory.java
 
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/ClientPoolFactory.java
index 5d9a1e6b921..18f76a91889 100644
--- 
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/ClientPoolFactory.java
+++ 
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/ClientPoolFactory.java
@@ -312,6 +312,7 @@ public class ClientPoolFactory {
                           conf.isPipeConnectorRPCThriftCompressionEnabled())
                       .setSelectorNumOfAsyncClientManager(
                           conf.getPipeAsyncConnectorSelectorNumber())
+                      
.setPrintLogWhenEncounterException(conf.isPrintLogWhenEncounterException())
                       .build(),
                   ThreadName.PIPE_ASYNC_CONNECTOR_CLIENT_POOL.getName()),
               new 
ClientPoolProperty.Builder<AsyncPipeDataTransferServiceClient>()
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 e29575d1477..96a26d0d01d 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
@@ -279,6 +279,7 @@ public class CommonConfig {
       Math.max(32, Runtime.getRuntime().availableProcessors() * 2);
   private int pipeAsyncConnectorMaxTsFileClientNumber =
       Math.max(16, Runtime.getRuntime().availableProcessors());
+  private boolean printLogWhenEncounterException = false;
 
   private double pipeSendTsFileRateLimitBytesPerSecond = 32 * MB;
   private double pipeAllSinksRateLimitBytesPerSecond = -1;
@@ -1199,6 +1200,18 @@ public class CommonConfig {
         "pipeAsyncConnectorMaxClientNumber is set to {}.", 
pipeAsyncConnectorMaxTsFileClientNumber);
   }
 
+  public boolean isPrintLogWhenEncounterException() {
+    return printLogWhenEncounterException;
+  }
+
+  public void setPrintLogWhenEncounterException(boolean 
printLogWhenEncounterException) {
+    if (this.printLogWhenEncounterException == printLogWhenEncounterException) 
{
+      return;
+    }
+    this.printLogWhenEncounterException = printLogWhenEncounterException;
+    logger.info("printLogWhenEncounterException is set to {}.", 
printLogWhenEncounterException);
+  }
+
   public boolean isSeperatedPipeHeartbeatEnabled() {
     return isSeperatedPipeHeartbeatEnabled;
   }
diff --git 
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/PipeDescriptor.java
 
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/PipeDescriptor.java
index 9c46978b7d4..5e11df2d086 100644
--- 
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/PipeDescriptor.java
+++ 
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/PipeDescriptor.java
@@ -609,6 +609,11 @@ public class PipeDescriptor {
     if (value != null) {
       config.setPipeAllSinksRateLimitBytesPerSecond(Double.parseDouble(value));
     }
+
+    value = parserPipeConfig(properties, "print_log_when_encounter_exception", 
isHotModify);
+    if (value != null) {
+      config.setPrintLogWhenEncounterException(Boolean.parseBoolean(value));
+    }
   }
 
   private static String parserPipeConfig(