You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ju...@apache.org on 2026/03/19 02:31:48 UTC
(iotdb) 01/02: logger
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 <87...@users.noreply.github.com>
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()