diff --git a/integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeSyntaxIT.java b/integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeSyntaxIT.java
index 37ad97c2e573b..285b0170cb737 100644
--- a/integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeSyntaxIT.java
+++ b/integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeSyntaxIT.java
@@ -830,7 +830,7 @@ public void testPipePluginValidation() {
         fail();
       } catch (final SQLException e) {
         Assert.assertEquals(
-            "1603: Failed to get executable for PipePlugin TestProcessor, please check the URI.",
+            "701: Failed to get executable for PipePlugin TestProcessor, please check the URI.",
             e.getMessage());
       }
       try {
diff --git a/iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/TSStatusCode.java b/iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/TSStatusCode.java
index deb486ae46651..c2f76d294847c 100644
--- a/iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/TSStatusCode.java
+++ b/iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/TSStatusCode.java
@@ -231,6 +231,7 @@ public enum TSStatusCode {
   CREATE_PIPE_PLUGIN_ERROR(1600),
   DROP_PIPE_PLUGIN_ERROR(1601),
   PIPE_PLUGIN_LOAD_CLASS_ERROR(1602),
+  @Deprecated
   PIPE_PLUGIN_DOWNLOAD_ERROR(1603),
   CREATE_PIPE_PLUGIN_ON_DATANODE_ERROR(1604),
   DROP_PIPE_PLUGIN_ON_DATANODE_ERROR(1605),
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 7b5b23e644a23..f282a3d004d96 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
@@ -820,7 +820,7 @@ public SettableFuture<ConfigTaskResult> createPipePlugin(
       future.setException(
           new IoTDBException(
               String.format("Failed to create pipe plugin %s. " + pathError, pluginName),
-              TSStatusCode.CREATE_PIPE_PLUGIN_ERROR.getStatusCode()));
+              TSStatusCode.SEMANTIC_ERROR.getStatusCode()));
       return future;
     }
 
@@ -828,7 +828,7 @@ public SettableFuture<ConfigTaskResult> createPipePlugin(
       future.setException(
           new IoTDBException(
               "Failed to create pipe plugin, because the URI is empty.",
-              TSStatusCode.PIPE_PLUGIN_DOWNLOAD_ERROR.getStatusCode()));
+              TSStatusCode.SEMANTIC_ERROR.getStatusCode()));
       return future;
     }
 
@@ -843,7 +843,7 @@ public SettableFuture<ConfigTaskResult> createPipePlugin(
         future.setException(
             new IoTDBException(
                 "The scheme of URI is not set, please specify the scheme of URI.",
-                TSStatusCode.PIPE_PLUGIN_DOWNLOAD_ERROR.getStatusCode()));
+                TSStatusCode.SEMANTIC_ERROR.getStatusCode()));
         return future;
       }
       if (!uri.getScheme().equals("file")) {
@@ -882,7 +882,7 @@ public SettableFuture<ConfigTaskResult> createPipePlugin(
               "Failed to get executable for PipePlugin "
                   + createPipePluginStatement.getPluginName()
                   + ", please check the URI.",
-              TSStatusCode.PIPE_PLUGIN_DOWNLOAD_ERROR.getStatusCode()));
+              TSStatusCode.SEMANTIC_ERROR.getStatusCode()));
       return future;
     }
 
@@ -1799,7 +1799,7 @@ public SettableFuture<ConfigTaskResult> createPipe(
               String.format(
                   "Failed to create pipe %s, pipe name starting with \"%s\" are not allowed to be created.",
                   pipeName, PipeStaticMeta.SYSTEM_PIPE_PREFIX),
-              TSStatusCode.PIPE_ERROR.getStatusCode()));
+              TSStatusCode.SEMANTIC_ERROR.getStatusCode()));
       return future;
     }
 
@@ -1808,7 +1808,7 @@ public SettableFuture<ConfigTaskResult> createPipe(
       future.setException(
           new IoTDBException(
               String.format("Failed to create pipe %s, " + pathError, pipeName),
-              TSStatusCode.PIPE_ERROR.getStatusCode()));
+              TSStatusCode.SEMANTIC_ERROR.getStatusCode()));
       return future;
     }