You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ji...@apache.org on 2026/02/24 09:11:57 UTC
(iotdb) branch dev/1.3 updated: [To dev/1.3] Pipe: Optimized the error code of illegal pipe / pipe plugin name string (#17206)
This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a commit to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/dev/1.3 by this push:
new eaaf53fbe6d [To dev/1.3] Pipe: Optimized the error code of illegal pipe / pipe plugin name string (#17206)
eaaf53fbe6d is described below
commit eaaf53fbe6d2a3b2c395eca468bbde13ac313dac
Author: Caideyipi <87...@users.noreply.github.com>
AuthorDate: Tue Feb 24 17:11:51 2026 +0800
[To dev/1.3] Pipe: Optimized the error code of illegal pipe / pipe plugin name string (#17206)
* fix
* fix
---
.../apache/iotdb/pipe/it/autocreate/IoTDBPipeSyntaxIT.java | 4 ++--
.../src/main/java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../execution/config/executor/ClusterConfigTaskExecutor.java | 12 ++++++------
3 files changed, 9 insertions(+), 8 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..0eee0559a27 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
@@ -376,7 +376,7 @@ public class IoTDBPipeSyntaxIT extends AbstractPipeDualAutoIT {
+ "PipePlugin.jar"));
fail();
} catch (final SQLException e) {
- Assert.assertTrue(e.getMessage().contains("1600: Failed to create pipe plugin"));
+ Assert.assertTrue(e.getMessage().contains("701: Failed to create pipe plugin"));
}
}
@@ -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;
}