This is an automated email from the ASF dual-hosted git repository. Caideyipi pushed a commit to branch reset in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 6ed6f4a138b23a72539d2a9ffe57fa6a4b1ea856 Author: Caideyipi <[email protected]> AuthorDate: Wed May 6 14:45:14 2026 +0800 Update PipeTaskCoordinator.java --- .../confignode/manager/pipe/coordinator/task/PipeTaskCoordinator.java | 1 - 1 file changed, 1 deletion(-) diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/task/PipeTaskCoordinator.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/task/PipeTaskCoordinator.java index 8473865f49b..7137f9ff73e 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/task/PipeTaskCoordinator.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/task/PipeTaskCoordinator.java @@ -118,7 +118,6 @@ public class PipeTaskCoordinator { return status; } - /** Caller should ensure that the method is called in the lock {@link #lock()}. */ private TSStatus stopPipe(String pipeName) { final TSStatus status = configManager.getProcedureManager().stopPipe(pipeName);
