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

Reply via email to