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);

Reply via email to