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/10/19 05:52:35 UTC
[iotdb] 01/03: fix type in ConfigNodeRemoveCheck
This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a commit to branch beyyes/cluster_up
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 481bb7df292f630509fa2744690419f71e21d000
Author: Beyyes <cg...@foxmail.com>
AuthorDate: Sat Oct 15 17:03:03 2022 +0800
fix type in ConfigNodeRemoveCheck
---
.../java/org/apache/iotdb/confignode/conf/ConfigNodeRemoveCheck.java | 1 +
.../java/org/apache/iotdb/confignode/manager/ConsensusManager.java | 4 ++--
2 files changed, 3 insertions(+), 2 deletions(-)
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeRemoveCheck.java b/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeRemoveCheck.java
index 660595b456..a6a72dad59 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeRemoveCheck.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeRemoveCheck.java
@@ -112,6 +112,7 @@ public class ConfigNodeRemoveCheck {
}
if (status.getCode() == TSStatusCode.REMOVE_CONFIGNODE_FAILED.getStatusCode()) {
+ LOGGER.warn("Execute removeConfigNode failed for: {}", status.getMessage());
break;
}
}
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 f51c1ddd81..d4b442ac7c 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
@@ -57,7 +57,7 @@ public class ConsensusManager {
private static final Logger LOGGER = LoggerFactory.getLogger(ConsensusManager.class);
private static final ConfigNodeConfig CONF = ConfigNodeDescriptor.getInstance().getConf();
- private static final int SEED_CONFIG_NODE_Id = 0;
+ private static final int SEED_CONFIG_NODE_ID = 0;
private final IManager configManager;
@@ -152,7 +152,7 @@ public class ConsensusManager {
createPeerForConsensusGroup(
Collections.singletonList(
new TConfigNodeLocation(
- SEED_CONFIG_NODE_Id,
+ SEED_CONFIG_NODE_ID,
new TEndPoint(CONF.getInternalAddress(), CONF.getInternalPort()),
new TEndPoint(CONF.getInternalAddress(), CONF.getConsensusPort()))));
}