This is an automated email from the ASF dual-hosted git repository. justinchen pushed a commit to branch async-start-13 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 1a2c585effe2921bbe7913ec33642eced5f02459 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()
