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/11/18 15:50:38 UTC
[iotdb] branch master updated: [IOTDB-4809] Broadcast the RegionRouteMap to all DataNodes except the unknown ones (#8053)
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 9edc7ea31a [IOTDB-4809] Broadcast the RegionRouteMap to all DataNodes except the unknown ones (#8053)
9edc7ea31a is described below
commit 9edc7ea31a683e4af10f32d62b5cb235bf8a95cd
Author: YongzaoDan <33...@users.noreply.github.com>
AuthorDate: Fri Nov 18 23:50:32 2022 +0800
[IOTDB-4809] Broadcast the RegionRouteMap to all DataNodes except the unknown ones (#8053)
---
.../java/org/apache/iotdb/confignode/manager/load/LoadManager.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/LoadManager.java b/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/LoadManager.java
index b16692e8db..b601f03a2f 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/LoadManager.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/LoadManager.java
@@ -284,8 +284,9 @@ public class LoadManager {
public void broadcastLatestRegionRouteMap() {
Map<TConsensusGroupId, TRegionReplicaSet> latestRegionRouteMap = getLatestRegionRouteMap();
Map<Integer, TDataNodeLocation> dataNodeLocationMap = new ConcurrentHashMap<>();
+ // Broadcast the RegionRouteMap to all DataNodes except the unknown ones
getNodeManager()
- .filterDataNodeThroughStatus(NodeStatus.Running)
+ .filterDataNodeThroughStatus(NodeStatus.Running, NodeStatus.Removing, NodeStatus.ReadOnly)
.forEach(
onlineDataNode ->
dataNodeLocationMap.put(