(iotdb) branch pipe-log-nn updated: co-1

[justinchen]

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

justinchen pushed a commit to branch pipe-log-nn
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/pipe-log-nn by this push:
     new 0997a3bb3a5 co-1
0997a3bb3a5 is described below

commit 0997a3bb3a541aaca5486432883c22c8e473cb94
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Thu Mar 26 12:31:21 2026 +0800

    co-1
---
 .../commons/pipe/agent/task/subtask/PipeAbstractSinkSubtask.java | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

diff --git 
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/subtask/PipeAbstractSinkSubtask.java
 
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/subtask/PipeAbstractSinkSubtask.java
index ccf16bfa753..cb4bbe47c98 100644
--- 
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/subtask/PipeAbstractSinkSubtask.java
+++ 
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/subtask/PipeAbstractSinkSubtask.java
@@ -163,10 +163,11 @@ public abstract class PipeAbstractSinkSubtask extends 
PipeReportableSubtask {
    * @return {@code true} if the {@link PipeSubtask} should be stopped, {@code 
false} otherwise
    */
   private boolean onPipeConnectionException(final Throwable throwable) {
-    LOGGER.warn(
-        "PipeConnectionException occurred, {} retries to handshake with the 
target system.",
-        outputPipeSink.getClass().getName(),
-        throwable);
+    PipeLogger.log(
+        LOGGER::warn,
+        throwable,
+        "PipeConnectionException occurred, %s retries to handshake with the 
target system.",
+        outputPipeSink.getClass().getName());
 
     int retry = 0;
     while (retry < MAX_RETRY_TIMES) {