This is an automated email from the ASF dual-hosted git repository.

tanxinyu pushed a commit to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/dev/1.3 by this push:
     new 7449fe120d0 [To dev/1.3] Enhance remove unexisted confignode error 
message #15120
7449fe120d0 is described below

commit 7449fe120d0ffa63688a273093c434e5b23ae8e3
Author: Potato <[email protected]>
AuthorDate: Tue Mar 18 16:44:05 2025 +0800

    [To dev/1.3] Enhance remove unexisted confignode error message #15120
    
    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);

Reply via email to