You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ji...@apache.org on 2025/12/31 06:13:19 UTC
(iotdb) branch dev/1.3 updated: Disabled the repeatable pipe log when the receiver is down (#16963) (#16974)
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 <87...@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(