(iotdb) branch dev/1.3 updated: [To dev/1.3] Pipe: Switched some unnecessary log to debug level (#16259)

[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 1592865c7f1 [To dev/1.3] Pipe: Switched some unnecessary log to debug 
level (#16259)
1592865c7f1 is described below

commit 1592865c7f1df1ef546a60c53a016ef0b18a5b13
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Tue Aug 26 09:45:46 2025 +0800

    [To dev/1.3] Pipe: Switched some unnecessary log to debug level (#16259)
---
 .../confignode/client/async/handlers/rpc/PipePushMetaRPCHandler.java    | 2 +-
 .../manager/pipe/coordinator/runtime/heartbeat/PipeHeartbeatParser.java | 2 +-
 .../java/org/apache/iotdb/confignode/persistence/pipe/PipeTaskInfo.java | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/PipePushMetaRPCHandler.java
 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/PipePushMetaRPCHandler.java
index 9ef80e9f847..ffe15dd6466 100644
--- 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/PipePushMetaRPCHandler.java
+++ 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/PipePushMetaRPCHandler.java
@@ -50,7 +50,7 @@ public class PipePushMetaRPCHandler extends 
DataNodeAsyncRequestRPCHandler<TPush
     responseMap.put(requestId, response);
 
     if (response.getStatus().getCode() == 
TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
-      LOGGER.info("Successfully {} on DataNode: {}", requestType, 
formattedTargetLocation);
+      LOGGER.debug("Successfully {} on DataNode: {}", requestType, 
formattedTargetLocation);
     } else {
       LOGGER.error(
           "Failed to {} on DataNode: {}, response: {}",
diff --git 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/runtime/heartbeat/PipeHeartbeatParser.java
 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/runtime/heartbeat/PipeHeartbeatParser.java
index 56f1a0492de..ace07f5e2d3 100644
--- 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/runtime/heartbeat/PipeHeartbeatParser.java
+++ 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/runtime/heartbeat/PipeHeartbeatParser.java
@@ -185,7 +185,7 @@ public class PipeHeartbeatParser {
         final PipeTaskMeta runtimeMetaFromAgent =
             pipeTaskMetaMapFromAgent.get(runtimeMetaFromCoordinator.getKey());
         if (runtimeMetaFromAgent == null) {
-          LOGGER.info(
+          LOGGER.debug(
               "No corresponding Pipe is running in the reported DataRegion. 
runtimeMetaFromAgent is null, runtimeMetaFromCoordinator: {}",
               runtimeMetaFromCoordinator);
           continue;
diff --git 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/pipe/PipeTaskInfo.java
 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/pipe/PipeTaskInfo.java
index 8d5aa795e14..716be67dde0 100644
--- 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/pipe/PipeTaskInfo.java
+++ 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/pipe/PipeTaskInfo.java
@@ -661,7 +661,7 @@ public class PipeTaskInfo implements SnapshotProcessor {
         .forEach(
             pipeMeta -> {
               
pipeMetaKeeper.addPipeMeta(pipeMeta.getStaticMeta().getPipeName(), pipeMeta);
-              logger.ifPresent(l -> l.info("Recording pipe meta: {}", 
pipeMeta));
+              logger.ifPresent(l -> l.debug("Recording pipe meta: {}", 
pipeMeta));
             });
 
     return new TSStatus(TSStatusCode.SUCCESS_STATUS.getStatusCode());