This is an automated email from the ASF dual-hosted git repository. tanxinyu pushed a commit to branch enhance_remove_unexisted_confignode_error_message in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 8058dd7874bf034ad2b25314426a9e99ce1ceb48 Author: OneSizeFitQuorum <[email protected]> AuthorDate: Tue Mar 18 12:07:22 2025 +0800 finish 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);
