(iotdb) branch dev/1.3 updated: [To dev/1.3] Pipe: Fixed the config meta transfer problem (#16280) (#16282)

[justinchen]

This is an automated email from the ASF dual-hosted git repository.

justinchen pushed a commit to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/dev/1.3 by this push:
     new bb5b665c7c7 [To dev/1.3] Pipe: Fixed the config meta transfer problem 
(#16280) (#16282)
bb5b665c7c7 is described below

commit bb5b665c7c74a33c992a19b9b9855098da149aea
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Wed Aug 27 17:21:45 2025 +0800

    [To dev/1.3] Pipe: Fixed the config meta transfer problem (#16280) (#16282)
---
 .../pipe/agent/runtime/PipeConfigNodeRuntimeAgent.java        | 11 ++---------
 .../manager/pipe/agent/task/PipeConfigNodeTaskAgent.java      |  5 -----
 2 files changed, 2 insertions(+), 14 deletions(-)

diff --git 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/runtime/PipeConfigNodeRuntimeAgent.java
 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/runtime/PipeConfigNodeRuntimeAgent.java
index 372b0334a24..e8cc16a1edf 100644
--- 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/runtime/PipeConfigNodeRuntimeAgent.java
+++ 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/runtime/PipeConfigNodeRuntimeAgent.java
@@ -20,7 +20,6 @@
 package org.apache.iotdb.confignode.manager.pipe.agent.runtime;
 
 import org.apache.iotdb.commons.exception.IllegalPathException;
-import org.apache.iotdb.commons.exception.pipe.PipeRuntimeCriticalException;
 import org.apache.iotdb.commons.exception.pipe.PipeRuntimeException;
 import org.apache.iotdb.commons.pipe.agent.runtime.PipePeriodicalJobExecutor;
 import 
org.apache.iotdb.commons.pipe.agent.runtime.PipePeriodicalPhantomReferenceCleaner;
@@ -156,18 +155,12 @@ public class PipeConfigNodeRuntimeAgent implements 
IService {
 
     pipeTaskMeta.trackExceptionMessage(pipeRuntimeException);
 
-    // Stop all pipes locally if critical exception occurs
-    if (pipeRuntimeException instanceof PipeRuntimeCriticalException) {
-      PipeConfigNodeAgent.task().stopAllPipesWithCriticalException();
-    }
+    // Do not call "stopAllPipesWithCriticalException" because the sinks are 
not reused in
+    // ConfigNodeSubtask
   }
 
   /////////////////////////// Periodical Job Executor 
///////////////////////////
 
-  public void registerPeriodicalJob(String id, Runnable periodicalJob, long 
intervalInSeconds) {
-    pipePeriodicalJobExecutor.register(id, periodicalJob, intervalInSeconds);
-  }
-
   public void registerPhantomReferenceCleanJob(
       String id, Runnable periodicalJob, long intervalInSeconds) {
     pipePeriodicalPhantomReferenceCleaner.register(id, periodicalJob, 
intervalInSeconds);
diff --git 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/task/PipeConfigNodeTaskAgent.java
 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/task/PipeConfigNodeTaskAgent.java
index 3f66d8aa7c0..156a98b79d4 100644
--- 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/task/PipeConfigNodeTaskAgent.java
+++ 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/task/PipeConfigNodeTaskAgent.java
@@ -113,11 +113,6 @@ public class PipeConfigNodeTaskAgent extends PipeTaskAgent 
{
         .put(consensusGroupId, pipeTaskMeta);
   }
 
-  public void stopAllPipesWithCriticalException() {
-    super.stopAllPipesWithCriticalException(
-        ConfigNodeDescriptor.getInstance().getConf().getConfigNodeId());
-  }
-
   @Override
   protected TPushPipeMetaRespExceptionMessage 
handleSinglePipeMetaChangesInternal(
       final PipeMeta pipeMetaFromCoordinator) {