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 <[email protected]> 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();
