This is an automated email from the ASF dual-hosted git repository. tanxinyu pushed a commit to branch enhance_remove_unexisted_confignode_error_message_cp in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 2e7bd87a83f3065580441546663888c4dafd2c6e 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 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);
