[iotdb] branch master updated: [IOTDB-3900] start-confignode ，Failed to execute system command (#6805)

[caogaofei]

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

caogaofei 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 d7d6c9e0ab [IOTDB-3900] start-confignode ，Failed to execute system 
command (#6805)
d7d6c9e0ab is described below

commit d7d6c9e0ab844ff8e112029078062d9b5b8ee96b
Author: imquanke <39719966+imqua...@users.noreply.github.com>
AuthorDate: Thu Jul 28 15:39:07 2022 +0800

    [IOTDB-3900] start-confignode ，Failed to execute system command (#6805)
---
 .../client/sync/confignode/SyncConfigNodeClientPool.java     | 12 ++++++++++--
 1 file changed, 10 insertions(+), 2 deletions(-)

diff --git 
a/confignode/src/main/java/org/apache/iotdb/confignode/client/sync/confignode/SyncConfigNodeClientPool.java
 
b/confignode/src/main/java/org/apache/iotdb/confignode/client/sync/confignode/SyncConfigNodeClientPool.java
index eb0a7920cc..991a05af63 100644
--- 
a/confignode/src/main/java/org/apache/iotdb/confignode/client/sync/confignode/SyncConfigNodeClientPool.java
+++ 
b/confignode/src/main/java/org/apache/iotdb/confignode/client/sync/confignode/SyncConfigNodeClientPool.java
@@ -104,8 +104,16 @@ public class SyncConfigNodeClientPool {
       }
     }
     LOGGER.error("{} failed on ConfigNode {}", requestType, endPoint, 
lastException);
-    return new TSStatus(TSStatusCode.ALL_RETRY_FAILED.getStatusCode())
-        .setMessage("All retry failed due to" + lastException.getMessage());
+    switch (requestType) {
+      case REGISTER_CONFIG_NODE:
+        return new TConfigNodeRegisterResp(
+            RpcUtils.getStatus(
+                TSStatusCode.ALL_RETRY_FAILED,
+                "All retry failed due to" + lastException.getMessage()));
+      default:
+        return RpcUtils.getStatus(
+            TSStatusCode.ALL_RETRY_FAILED, "All retry failed due to" + 
lastException.getMessage());
+    }
   }
 
   public void addConsensusGroup(