(iotdb) branch master updated: Enhance remove unexisted datanode error message #15138

[tanxinyu]

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 f76c2c98251 Enhance remove unexisted datanode error message #15138
f76c2c98251 is described below

commit f76c2c98251c43b9931166bb83e116e87d85ba52
Author: Xiangpeng Hu <65238551+hxpser...@users.noreply.github.com>
AuthorDate: Wed Mar 19 20:46:19 2025 +0800

    Enhance remove unexisted datanode error message #15138
---
 .../plan/execution/config/executor/ClusterConfigTaskExecutor.java | 8 ++++++++
 1 file changed, 8 insertions(+)

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 3fee768889c..06c79a7fe15 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
@@ -2864,6 +2864,14 @@ public class ClusterConfigTaskExecutor implements 
IConfigTaskExecutor {
         nodeIds.removeAll(invalidNodeIds);
       }
 
+      if (nodeIds.size() != 1) {
+        LOGGER.error(
+            "The DataNode to be removed is not in the cluster, or the input 
format is incorrect.");
+        future.setException(
+            new IOException(
+                "The DataNode to be removed is not in the cluster, or the 
input format is incorrect."));
+      }
+
       LOGGER.info("Starting to remove DataNode with nodeIds: {}", nodeIds);
 
       final Set<Integer> finalNodeIds = nodeIds;