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(

Reply via email to