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) {

Reply via email to