diff --git a/hbase-rsgroup/src/main/java/org/apache/hadoop/hbase/rsgroup/RSGroupBasedLoadBalancer.java b/hbase-rsgroup/src/main/java/org/apache/hadoop/hbase/rsgroup/RSGroupBasedLoadBalancer.java index bc36bc2..f82636c 100644 --- a/hbase-rsgroup/src/main/java/org/apache/hadoop/hbase/rsgroup/RSGroupBasedLoadBalancer.java +++ b/hbase-rsgroup/src/main/java/org/apache/hadoop/hbase/rsgroup/RSGroupBasedLoadBalancer.java @@ -327,7 +327,6 @@ public class RSGroupBasedLoadBalancer implements RSGroupableBalancer { Map> existingAssignments) throws HBaseIOException{ Map> correctAssignments = new TreeMap<>(); - List misplacedRegions = new LinkedList<>(); correctAssignments.put(LoadBalancer.BOGUS_SERVER_NAME, new LinkedList<>()); for (Map.Entry> assignments : existingAssignments.entrySet()){ ServerName sName = assignments.getKey(); @@ -350,15 +349,6 @@ public class RSGroupBasedLoadBalancer implements RSGroupableBalancer { } } - //TODO bulk unassign? - //unassign misplaced regions, so that they are assigned to correct groups. - for(HRegionInfo info: misplacedRegions) { - try { - this.masterServices.getAssignmentManager().unassign(info); - } catch (IOException e) { - throw new HBaseIOException(e); - } - } return correctAssignments; }