From 40c0f319f6169dc49aed64318317ec3017d09fd9 Mon Sep 17 00:00:00 2001
From: luoluoyuyu <zhenyu@apache.org>
Date: Thu, 11 Jun 2026 16:06:38 +0800
Subject: [PATCH] Pipe: drop sink before processor and source on task drop.

Stop the connector first so downstream forwarding stops promptly when a pipe is dropped.
---
 .../org/apache/iotdb/db/pipe/agent/task/PipeDataNodeTask.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/PipeDataNodeTask.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/PipeDataNodeTask.java
index 0d4e50cabef1f..1c199eb6487a0 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/PipeDataNodeTask.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/PipeDataNodeTask.java
@@ -68,9 +68,9 @@ public void create() {
   @Override
   public void drop() {
     final long startTime = System.currentTimeMillis();
-    sourceStage.drop();
-    processorStage.drop();
     sinkStage.drop();
+    processorStage.drop();
+    sourceStage.drop();
     LOGGER.info(
         DataNodePipeMessages.DROP_PIPE_DN_TASK_SUCCESSFULLY_WITHIN_MS,
         this,