This is an automated email from the ASF dual-hosted git repository. ddanielr 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 2b5e3ebe65 makes coordinator logs less chatty (#5556) 2b5e3ebe65 is described below commit 2b5e3ebe6593be70ab7bf777f9aca45e7bfad581 Author: Keith Turner <ktur...@apache.org> AuthorDate: Tue May 20 13:51:09 2025 -0400 makes coordinator logs less chatty (#5556) After these changes, under normal conditions, there will only be two debug messages per compaction in the coordinator. One message when a compactor starts a compaction and one when it finishes. --- .../java/org/apache/accumulo/coordinator/CompactionCoordinator.java | 6 +++--- 1 file changed, 3 insertions(+), 3 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 2079bfe0da..b74eedd5f1 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 @@ -422,7 +422,7 @@ public class CompactionCoordinator extends AbstractServer implements try { TabletClientService.Client client = null; try { - LOG.debug("Contacting tablet server {} to get external compaction summaries", + LOG.trace("Contacting tablet server {} to get external compaction summaries", tsi.getHostPort()); client = getTabletServerConnection(tsi); List<TCompactionQueueSummary> summaries = @@ -582,7 +582,7 @@ public class CompactionCoordinator extends AbstractServer implements } var extent = KeyExtent.fromThrift(textent); - LOG.info("Compaction completed, id: {}, stats: {}, extent: {}", externalCompactionId, stats, + LOG.debug("Compaction completed, id: {}, stats: {}, extent: {}", externalCompactionId, stats, extent); final var ecid = ExternalCompactionId.of(externalCompactionId); compactionFinalizer.commitCompaction(ecid, extent, stats.fileSize, stats.entriesWritten); @@ -630,7 +630,7 @@ public class CompactionCoordinator extends AbstractServer implements throw new AccumuloSecurityException(credentials.getPrincipal(), SecurityErrorCode.PERMISSION_DENIED).asThriftException(); } - STATUS_LOG.debug("Compaction status update, id: {}, timestamp: {}, update: {}", + STATUS_LOG.trace("Compaction status update, id: {}, timestamp: {}, update: {}", externalCompactionId, timestamp, update); final RunningCompaction rc = RUNNING_CACHE.get(ExternalCompactionId.of(externalCompactionId)); if (null != rc) {