This is an automated email from the ASF dual-hosted git repository. domgarguilo 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 c72f2b207a Fix resource group mapping in GarbageCollector compactor logging check (#5488) c72f2b207a is described below commit c72f2b207a28792d8b8559454d4e1a150953ec7a Author: Dom G. <domgargu...@apache.org> AuthorDate: Wed Apr 23 10:25:06 2025 -0400 Fix resource group mapping in GarbageCollector compactor logging check (#5488) --- .../src/main/java/org/apache/accumulo/gc/SimpleGarbageCollector.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/server/gc/src/main/java/org/apache/accumulo/gc/SimpleGarbageCollector.java b/server/gc/src/main/java/org/apache/accumulo/gc/SimpleGarbageCollector.java index 46e4fe8c8d..75a237686f 100644 --- a/server/gc/src/main/java/org/apache/accumulo/gc/SimpleGarbageCollector.java +++ b/server/gc/src/main/java/org/apache/accumulo/gc/SimpleGarbageCollector.java @@ -328,7 +328,7 @@ public class SimpleGarbageCollector extends AbstractServer implements Iface { String resourceGroup = tconf.get(TableLoadBalancer.TABLE_ASSIGNMENT_GROUP_PROPERTY); resourceGroup = resourceGroup == null ? Constants.DEFAULT_RESOURCE_GROUP_NAME : resourceGroup; - resourceMapping.getOrDefault(resourceGroup, new HashSet<>()).add(tid); + resourceMapping.computeIfAbsent(resourceGroup, k -> new HashSet<>()).add(tid); } for (Entry<String,Set<TableId>> e : resourceMapping.entrySet()) { if (ExternalCompactionUtil.countCompactors(e.getKey(), getContext()) == 0) { @@ -437,7 +437,7 @@ public class SimpleGarbageCollector extends AbstractServer implements Iface { false, addresses); server.startThriftServer("GC Monitor Service"); setHostname(server.address); - log.debug("Starting garbage collector listening on " + server.address); + log.debug("Starting garbage collector listening on {}", server.address); return server.address; }