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/09/02 03:14:52 UTC
[iotdb] branch beyyes/perfect_cluster_node_changing_process updated: make code tidy
This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a commit to branch beyyes/perfect_cluster_node_changing_process
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/beyyes/perfect_cluster_node_changing_process by this push:
new 30d009e880 make code tidy
30d009e880 is described below
commit 30d009e88057c4f9340eecf9dfa02b76db048a8f
Author: Beyyes <cg...@foxmail.com>
AuthorDate: Fri Sep 2 11:14:34 2022 +0800
make code tidy
---
.../java/org/apache/iotdb/confignode/manager/ConsensusManager.java | 3 ++-
.../main/java/org/apache/iotdb/confignode/persistence/NodeInfo.java | 4 ++--
.../apache/iotdb/confignode/procedure/env/ConfigNodeProcedureEnv.java | 3 ++-
3 files changed, 6 insertions(+), 4 deletions(-)
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConsensusManager.java b/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConsensusManager.java
index db15d49a43..bc1075ce5c 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConsensusManager.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConsensusManager.java
@@ -136,7 +136,8 @@ public class ConsensusManager {
* @param configNodeLocation The new ConfigNode
* @throws AddPeerException When addPeer doesn't success
*/
- public void addPeerForConsensusGroup(TConfigNodeLocation configNodeLocation) throws AddPeerException {
+ public void addPeerForConsensusGroup(TConfigNodeLocation configNodeLocation)
+ throws AddPeerException {
boolean result =
consensusImpl
.addPeer(
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/persistence/NodeInfo.java b/confignode/src/main/java/org/apache/iotdb/confignode/persistence/NodeInfo.java
index ae120c8000..d5505d8664 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/persistence/NodeInfo.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/persistence/NodeInfo.java
@@ -70,8 +70,8 @@ import static org.apache.iotdb.confignode.conf.ConfigNodeConstant.METRIC_STATUS_
import static org.apache.iotdb.confignode.conf.ConfigNodeConstant.METRIC_TAG_TOTAL;
/**
- * The NodeInfo stores cluster node information. The cluster node information including:
- * 1. DataNode information 2. ConfigNode information
+ * The NodeInfo stores cluster node information. The cluster node information including: 1. DataNode
+ * information 2. ConfigNode information
*/
public class NodeInfo implements SnapshotProcessor {
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/procedure/env/ConfigNodeProcedureEnv.java b/confignode/src/main/java/org/apache/iotdb/confignode/procedure/env/ConfigNodeProcedureEnv.java
index cd844ba0aa..0e8029d4c2 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/procedure/env/ConfigNodeProcedureEnv.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/procedure/env/ConfigNodeProcedureEnv.java
@@ -200,7 +200,8 @@ public class ConfigNodeProcedureEnv {
* @param configNodeLocation The new ConfigNode
* @throws AddPeerException When addPeer doesn't success
*/
- public void addPeerForConsensusGroup(TConfigNodeLocation configNodeLocation) throws AddPeerException {
+ public void addPeerForConsensusGroup(TConfigNodeLocation configNodeLocation)
+ throws AddPeerException {
configManager.getConsensusManager().addPeerForConsensusGroup(configNodeLocation);
}