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()