This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new 385d0df5f9f Enhance remove unexisted confignode error message #15117
385d0df5f9f is described below
commit 385d0df5f9f06af7d893d0d17ac8d2fb4920d3ca
Author: Potato <[email protected]>
AuthorDate: Tue Mar 18 14:23:01 2025 +0800
Enhance remove unexisted confignode error message #15117
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 8628d31ef5f..64078ed0088 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
@@ -2928,7 +2928,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);