(iotdb) branch logger-pipe updated: sit

[justinchen]

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

justinchen pushed a commit to branch logger-pipe
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/logger-pipe by this push:
     new e90ececf29e sit
e90ececf29e is described below

commit e90ececf29e52634ac08605859d7b009d219904f
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Wed Feb 4 19:09:25 2026 +0800

    sit
---
 .../apache/iotdb/confignode/persistence/pipe/PipeTaskInfo.java |  2 +-
 .../execution/config/executor/ClusterConfigTaskExecutor.java   | 10 ++++++----
 .../java/org/apache/iotdb/db/utils/ErrorHandlingUtils.java     |  1 +
 3 files changed, 8 insertions(+), 5 deletions(-)

diff --git 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/pipe/PipeTaskInfo.java
 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/pipe/PipeTaskInfo.java
index 96eab13aec2..929024a0689 100644
--- 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/pipe/PipeTaskInfo.java
+++ 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/pipe/PipeTaskInfo.java
@@ -185,7 +185,7 @@ public class PipeTaskInfo implements SnapshotProcessor {
         String.format(
             "Failed to create pipe %s, %s",
             createPipeRequest.getPipeName(), PIPE_ALREADY_EXIST_MSG);
-    LOGGER.warn(exceptionMessage);
+    LOGGER.info(exceptionMessage);
     throw new PipeException(exceptionMessage);
   }
 
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/executor/ClusterConfigTaskExecutor.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/executor/ClusterConfigTaskExecutor.java
index 65c86754c70..52c85334c18 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/executor/ClusterConfigTaskExecutor.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/executor/ClusterConfigTaskExecutor.java
@@ -1151,10 +1151,12 @@ public class ClusterConfigTaskExecutor implements 
IConfigTaskExecutor {
                   
.setIfExistsCondition(dropPipePluginStatement.hasIfExistsCondition())
                   .setIsTableModel(dropPipePluginStatement.isTableModel()));
       if (TSStatusCode.SUCCESS_STATUS.getStatusCode() != 
executionStatus.getCode()) {
-        LOGGER.warn(
-            "[{}] Failed to drop pipe plugin {}.",
-            executionStatus,
-            dropPipePluginStatement.getPluginName());
+        if (TSStatusCode.PIPE_NOT_EXIST_ERROR.getStatusCode() != 
executionStatus.getCode()) {
+          LOGGER.warn(
+              "[{}] Failed to drop pipe plugin {}.",
+              executionStatus,
+              dropPipePluginStatement.getPluginName());
+        }
         future.setException(new IoTDBException(executionStatus));
       } else {
         future.set(new ConfigTaskResult(TSStatusCode.SUCCESS_STATUS));
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/ErrorHandlingUtils.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/ErrorHandlingUtils.java
index b70d51cca95..34d2e9bf82c 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/ErrorHandlingUtils.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/ErrorHandlingUtils.java
@@ -117,6 +117,7 @@ public class ErrorHandlingUtils {
             || status.getCode() == 
TSStatusCode.EXECUTE_UDF_ERROR.getStatusCode()
             || status.getCode() == 
TSStatusCode.TEMPLATE_INCOMPATIBLE.getStatusCode()
             || status.getCode() == 
TSStatusCode.PATH_ALREADY_EXIST.getStatusCode()
+            || status.getCode() == 
TSStatusCode.PIPE_NOT_EXIST_ERROR.getStatusCode()
             || status.getCode() == TSStatusCode.QUERY_TIMEOUT.getStatusCode()) 
{
           LOGGER.info(message);
         } else {