This is an automated email from the ASF dual-hosted git repository.
tanxinyu 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 7449fe120d0 [To dev/1.3] Enhance remove unexisted confignode error
message #15120
7449fe120d0 is described below
commit 7449fe120d0ffa63688a273093c434e5b23ae8e3
Author: Potato <[email protected]>
AuthorDate: Tue Mar 18 16:44:05 2025 +0800
[To dev/1.3] Enhance remove unexisted confignode error message #15120
Signed-off-by: OneSizeFitQuorum <[email protected]>
---
.../plan/execution/config/executor/ClusterConfigTaskExecutor.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
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 a26185b832c..dbf9db790ca 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
@@ -2756,7 +2756,9 @@ public class ClusterConfigTaskExecutor implements
IConfigTaskExecutor {
if (removeConfigNodeLocations.size() != 1) {
LOGGER.error(
"The ConfigNode to be removed is not in the cluster, or the input
format is incorrect.");
- future.set(new ConfigTaskResult(TSStatusCode.REMOVE_CONFIGNODE_ERROR));
+ future.setException(
+ new IOException(
+ "The ConfigNode to be removed is not in the cluster, or the
input format is incorrect."));
}
TConfigNodeLocation configNodeLocation =
removeConfigNodeLocations.get(0);