This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a commit to branch login-13
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/login-13 by this push:
new 26bf21fc6c6 fix
26bf21fc6c6 is described below
commit 26bf21fc6c6ad3c2039701f16d09fd108c65df9a
Author: Caideyipi <[email protected]>
AuthorDate: Sat Feb 14 12:21:15 2026 +0800
fix
---
.../apache/iotdb/pipe/it/autocreate/IoTDBPipeSyntaxIT.java | 2 +-
.../src/main/java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../execution/config/executor/ClusterConfigTaskExecutor.java | 12 ++++++------
3 files changed, 8 insertions(+), 7 deletions(-)
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 37ad97c2e57..285b0170cb7 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 class IoTDBPipeSyntaxIT extends
AbstractPipeDualAutoIT {
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 deb486ae466..c2f76d29484 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 7b5b23e644a..f282a3d004d 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 class ClusterConfigTaskExecutor implements
IConfigTaskExecutor {
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 class ClusterConfigTaskExecutor implements
IConfigTaskExecutor {
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 class ClusterConfigTaskExecutor implements
IConfigTaskExecutor {
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 class ClusterConfigTaskExecutor implements
IConfigTaskExecutor {
"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 class ClusterConfigTaskExecutor implements
IConfigTaskExecutor {
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 class ClusterConfigTaskExecutor implements
IConfigTaskExecutor {
future.setException(
new IoTDBException(
String.format("Failed to create pipe %s, " + pathError,
pipeName),
- TSStatusCode.PIPE_ERROR.getStatusCode()));
+ TSStatusCode.SEMANTIC_ERROR.getStatusCode()));
return future;
}
