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:47 UTC
(iotdb) branch async-start-13 updated (72d4d2b3918 -> 1436a1b782c)
This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a change to branch async-start-13
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 72d4d2b3918 [To dev/1.3] Pipe: Optimized the OPC UA logic to avoid potential bugs (#17310)
new 1a2c585effe logger
new 1436a1b782c async
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../org/apache/iotdb/db/pipe/agent/runtime/PipeAgentLauncher.java | 2 +-
.../apache/iotdb/db/pipe/agent/runtime/PipeDataNodeRuntimeAgent.java | 3 +--
.../commons/pipe/agent/runtime/AbstractPipePeriodicalJobExecutor.java | 4 ++++
3 files changed, 6 insertions(+), 3 deletions(-)
(iotdb) 01/02: logger
Posted by ju...@apache.org.
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()
(iotdb) 02/02: async
Posted by ju...@apache.org.
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 1436a1b782c51416d8ff1281d2fa78fae36f2018
Author: Caideyipi <87...@users.noreply.github.com>
AuthorDate: Thu Mar 19 10:16:02 2026 +0800
async
---
.../apache/iotdb/db/pipe/agent/runtime/PipeDataNodeRuntimeAgent.java | 3 +--
.../commons/pipe/agent/runtime/AbstractPipePeriodicalJobExecutor.java | 4 ++++
2 files changed, 5 insertions(+), 2 deletions(-)
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/runtime/PipeDataNodeRuntimeAgent.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/runtime/PipeDataNodeRuntimeAgent.java
index 9da6c154adc..437c15bdc1c 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/runtime/PipeDataNodeRuntimeAgent.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/runtime/PipeDataNodeRuntimeAgent.java
@@ -91,9 +91,8 @@ public class PipeDataNodeRuntimeAgent implements IService {
@Override
public synchronized void start() throws StartupException {
PipeConfig.getInstance().printAllConfigs();
- PipeAgentLauncher.launchPipeTaskAgent();
-
pipePeriodicalJobExecutor.start();
+ pipePeriodicalJobExecutor.runDirectly(PipeAgentLauncher::launchPipeTaskAgent);
if (PipeConfig.getInstance().getPipeEventReferenceTrackingEnabled()) {
pipePeriodicalPhantomReferenceCleaner.start();
diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/runtime/AbstractPipePeriodicalJobExecutor.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/runtime/AbstractPipePeriodicalJobExecutor.java
index c6e24b5f475..08b65d103ee 100644
--- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/runtime/AbstractPipePeriodicalJobExecutor.java
+++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/runtime/AbstractPipePeriodicalJobExecutor.java
@@ -110,6 +110,10 @@ public abstract class AbstractPipePeriodicalJobExecutor {
}
}
+ public void runDirectly(final Runnable command) {
+ executorService.execute(command);
+ }
+
@TestOnly
public void clear() {
periodicalJobs.clear();