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;
   }
 

Reply via email to