This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch optimize-pipe-after-stop in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit f7bacc5df226777cbad92290911935c9ee4582f6 Author: Steve Yurong Su <[email protected]> AuthorDate: Mon Mar 10 13:34:54 2025 +0800 Update PipeDataNodeTaskAgent.java --- .../org/apache/iotdb/db/pipe/agent/task/PipeDataNodeTaskAgent.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/PipeDataNodeTaskAgent.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/PipeDataNodeTaskAgent.java index 741a2de6803..f521698b87c 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/PipeDataNodeTaskAgent.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/PipeDataNodeTaskAgent.java @@ -125,6 +125,11 @@ public class PipeDataNodeTaskAgent extends PipeTaskAgent { } private void restartPipeToReloadResourceIfNeeded(final PipeMeta pipeMeta) { + if (System.currentTimeMillis() - pipeMeta.getStaticMeta().getCreationTime() + < PipeConfig.getInstance().getPipeStuckRestartMinIntervalMs()) { + return; + } + final AtomicLong lastRestartTime = PIPE_NAME_TO_LAST_RESTART_TIME_MAP.get(pipeMeta.getStaticMeta().getPipeName()); if (lastRestartTime != null
