fanhualta commented on a change in pull request #3191:
URL: https://github.com/apache/iotdb/pull/3191#discussion_r648466513
##########
File path:
cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterPlanRouter.java
##########
@@ -144,6 +151,29 @@ private PartitionGroup routePlan(ShowChildPathsPlan plan) {
throw new UnsupportedPlanException(plan);
}
+ public Map<PhysicalPlan, PartitionGroup>
splitAndRouteChangeMembershipLog(Log log) {
+ Map<PhysicalPlan, PartitionGroup> result = new HashMap<>();
+ LogPlan plan = new LogPlan(log.serialize());
+ List<Node> oldRing = new ArrayList<>(partitionTable.getAllNodes());
+ if (log instanceof AddNodeLog) {
+ oldRing.remove(((AddNodeLog) log).getNewNode());
+ } else if (log instanceof RemoveNodeLog) {
+ if (!oldRing.contains(((RemoveNodeLog) log).getRemovedNode())) {
+ oldRing.add(((RemoveNodeLog) log).getRemovedNode());
+ oldRing.sort(Comparator.comparingInt(Node::getNodeIdentifier));
+ }
+ }
+ for (PartitionGroup partitionGroup :
partitionTable.calculateGlobalGroups(oldRing)) {
+ // It doesn't need to notify the data group which will be removed from
cluster.
+ if (log instanceof RemoveNodeLog
+ && partitionGroup.getHeader().equals(((RemoveNodeLog)
log).getRemovedNode())) {
+ continue;
Review comment:
I have checked all errors like this and fixed them, it's due to the last
commit.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
