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

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


The following commit(s) were added to refs/heads/async-start by this push:
     new b98b5e4bbe7 logger
b98b5e4bbe7 is described below

commit b98b5e4bbe7c5966c9e7e53e50168da3655d21ab
Author: Caideyipi <[email protected]>
AuthorDate: Thu Mar 19 10:06:43 2026 +0800

    logger
---
 .../java/org/apache/iotdb/db/pipe/agent/runtime/PipeAgentLauncher.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/runtime/PipeAgentLauncher.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/runtime/PipeAgentLauncher.java
index 77f2b143966..1e1d3388f75 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/runtime/PipeAgentLauncher.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/runtime/PipeAgentLauncher.java
@@ -161,7 +161,7 @@ class PipeAgentLauncher {
         
ConfigNodeClientManager.getInstance().borrowClient(ConfigNodeInfo.CONFIG_REGION_ID))
 {
       final TGetAllPipeInfoResp getAllPipeInfoResp = 
configNodeClient.getAllPipeInfo();
       if (getAllPipeInfoResp.getStatus().getCode() != 
TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
-        throw new StartupException("Failed to get pipe task meta from config 
node.");
+        LOGGER.warn("Failed to get pipe metas, will be synced by configNode 
later...");
       }
 
       PipeDataNodeAgent.task()

Reply via email to