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

jackietien pushed a commit to branch rc/2.0.5
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit 866205155e3423481b37987542e181a1bd8bc5c2
Author: Zhenyu Luo <[email protected]>
AuthorDate: Tue Jul 22 15:44:27 2025 +0800

    Pipe: Update the log of the heartbeat process reported by DN to CN (#15983)
    
    (cherry picked from commit 0340423366a5d990ffb953218ff1d330dd4306f4)
---
 .../pipe/coordinator/runtime/heartbeat/PipeHeartbeatParser.java      | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

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 e2303fecdea..bb046102283 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,9 +185,8 @@ public class PipeHeartbeatParser {
         final PipeTaskMeta runtimeMetaFromAgent =
             pipeTaskMetaMapFromAgent.get(runtimeMetaFromCoordinator.getKey());
         if (runtimeMetaFromAgent == null) {
-          LOGGER.warn(
-              "PipeRuntimeCoordinator meets error in updating pipeMetaKeeper, "
-                  + "runtimeMetaFromAgent is null, runtimeMetaFromCoordinator: 
{}",
+          LOGGER.info(
+              "No corresponding Pipe is running in the reported DataRegion. 
runtimeMetaFromAgent is null, runtimeMetaFromCoordinator: {}",
               runtimeMetaFromCoordinator);
           continue;
         }

Reply via email to