This is an automated email from the ASF dual-hosted git repository. mmiller pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/accumulo.git
The following commit(s) were added to refs/heads/main by this push: new 4213d76 Fix redundant TableId creation in TableLoadBalancer (#2060) 4213d76 is described below commit 4213d76c2b5fcbeeb4163db04c1fb8b7226cfe22 Author: Mike Miller <mmil...@apache.org> AuthorDate: Fri Apr 30 09:34:51 2021 -0400 Fix redundant TableId creation in TableLoadBalancer (#2060) --- .../org/apache/accumulo/core/spi/balancer/TableLoadBalancer.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/core/src/main/java/org/apache/accumulo/core/spi/balancer/TableLoadBalancer.java b/core/src/main/java/org/apache/accumulo/core/spi/balancer/TableLoadBalancer.java index f046984..02aef99 100644 --- a/core/src/main/java/org/apache/accumulo/core/spi/balancer/TableLoadBalancer.java +++ b/core/src/main/java/org/apache/accumulo/core/spi/balancer/TableLoadBalancer.java @@ -108,10 +108,8 @@ public class TableLoadBalancer implements TabletBalancer { public void getAssignments(AssignmentParameters params) { // separate the unassigned into tables Map<TableId,Map<TabletId,TabletServerId>> groupedUnassigned = new HashMap<>(); - params.unassignedTablets() - .forEach((tid, lastTserver) -> groupedUnassigned - .computeIfAbsent(TableId.of(tid.getTable().canonical()), k -> new HashMap<>()) - .put(tid, lastTserver)); + params.unassignedTablets().forEach((tid, lastTserver) -> groupedUnassigned + .computeIfAbsent(tid.getTable(), k -> new HashMap<>()).put(tid, lastTserver)); for (Entry<TableId,Map<TabletId,TabletServerId>> e : groupedUnassigned.entrySet()) { Map<TabletId,TabletServerId> newAssignments = new HashMap<>(); getBalancerForTable(e.getKey()).getAssignments(