You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ca...@apache.org on 2022/07/28 07:39:13 UTC
[iotdb] branch master updated: [IOTDB-3900] start-confignode ，Failed to execute system command (#6805)
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 <39...@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(