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 2ce89e0ec4 uses specific logger for compaction coordinator status update (#4489) 2ce89e0ec4 is described below commit 2ce89e0ec4a6cc57b139e1f33f4a8f51ebb6b211 Author: Keith Turner <ktur...@apache.org> AuthorDate: Wed May 1 16:19:55 2024 -0400 uses specific logger for compaction coordinator status update (#4489) --- .../org/apache/accumulo/coordinator/CompactionCoordinator.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/server/compaction-coordinator/src/main/java/org/apache/accumulo/coordinator/CompactionCoordinator.java b/server/compaction-coordinator/src/main/java/org/apache/accumulo/coordinator/CompactionCoordinator.java index 2b0dee53b7..9ac4ddd27a 100644 --- a/server/compaction-coordinator/src/main/java/org/apache/accumulo/coordinator/CompactionCoordinator.java +++ b/server/compaction-coordinator/src/main/java/org/apache/accumulo/coordinator/CompactionCoordinator.java @@ -100,6 +100,9 @@ public class CompactionCoordinator extends AbstractServer implements CompactionCoordinatorService.Iface, LiveTServerSet.Listener { private static final Logger LOG = LoggerFactory.getLogger(CompactionCoordinator.class); + + private static final Logger STATUS_LOG = + LoggerFactory.getLogger(CompactionCoordinator.class.getName() + ".compaction.status"); private static final long TIME_BETWEEN_GC_CHECKS = 5000; protected static final QueueSummaries QUEUE_SUMMARIES = new QueueSummaries(); @@ -585,8 +588,8 @@ public class CompactionCoordinator extends AbstractServer throw new AccumuloSecurityException(credentials.getPrincipal(), SecurityErrorCode.PERMISSION_DENIED).asThriftException(); } - LOG.debug("Compaction status update, id: {}, timestamp: {}, update: {}", externalCompactionId, - timestamp, update); + STATUS_LOG.debug("Compaction status update, id: {}, timestamp: {}, update: {}", + externalCompactionId, timestamp, update); final RunningCompaction rc = RUNNING_CACHE.get(ExternalCompactionId.of(externalCompactionId)); if (null != rc) { rc.addUpdate(timestamp, update);