This is an automated email from the ASF dual-hosted git repository. kturner pushed a commit to branch 2.1 in repository https://gitbox.apache.org/repos/asf/accumulo.git
The following commit(s) were added to refs/heads/2.1 by this push: new 69381b494d add id to compaction service logging (#4084) 69381b494d is described below commit 69381b494de5e191b0f6dfcc3ba0c1bae8eb601e Author: Keith Turner <ktur...@apache.org> AuthorDate: Wed Dec 20 13:48:36 2023 -0800 add id to compaction service logging (#4084) --- .../apache/accumulo/tserver/compactions/CompactionService.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/server/tserver/src/main/java/org/apache/accumulo/tserver/compactions/CompactionService.java b/server/tserver/src/main/java/org/apache/accumulo/tserver/compactions/CompactionService.java index 8b5f5624ac..3dd2e32b36 100644 --- a/server/tserver/src/main/java/org/apache/accumulo/tserver/compactions/CompactionService.java +++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/compactions/CompactionService.java @@ -193,7 +193,8 @@ public class CompactionService { try { Optional<Compactable.Files> files = compactable.getFiles(myId, kind); if (files.isEmpty() || files.orElseThrow().candidates.isEmpty()) { - log.trace("Compactable returned no files {} {}", compactable.getExtent(), kind); + log.trace("Compactable returned no files {} {} {}", myId, compactable.getExtent(), + kind); } else { CompactionPlan plan = getCompactionPlan(kind, files.orElseThrow(), compactable); submitCompactionJob(plan, files.orElseThrow(), compactable, completionCallback); @@ -276,15 +277,15 @@ public class CompactionService { Compactable compactable) { PlanningParameters params = new CpPlanParams(kind, compactable, files); - log.trace("Planning compactions {} {} {} {}", planner.getClass().getName(), + log.trace("Planning compactions {} {} {} {} {}", myId, planner.getClass().getName(), compactable.getExtent(), kind, files); CompactionPlan plan; try { plan = planner.makePlan(params); } catch (RuntimeException e) { - log.debug("Planner failed {} {} {} {}", planner.getClass().getName(), compactable.getExtent(), - kind, files, e); + log.debug("Planner failed {} {} {} {} {}", myId, planner.getClass().getName(), + compactable.getExtent(), kind, files, e); throw e; }