(accumulo) branch 2.1 updated: Reduce verbose log messages (#5980)

[ddanielr]

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 7d823f6bb3 Reduce verbose log messages (#5980)
7d823f6bb3 is described below

commit 7d823f6bb3552d6e39a8a9f35f1fe6a43c1998bc
Author: Daniel Roberts <ddani...@gmail.com>
AuthorDate: Fri Nov 21 21:18:08 2025 -0500

    Reduce verbose log messages (#5980)
    
    * Reduce verbose log messages
    
    Moves some of these log messages from debug to trace to help reduce
    output in log files.
    
    * Adds store name and separates deadlog lines
    
    Adds the store name as a log message prefix.
    Separates the map print log message from a single line message into a
    line per dead tserver
---
 .../org/apache/accumulo/manager/TabletGroupWatcher.java  | 16 ++++++++++------
 1 file changed, 10 insertions(+), 6 deletions(-)

diff --git 
a/server/manager/src/main/java/org/apache/accumulo/manager/TabletGroupWatcher.java
 
b/server/manager/src/main/java/org/apache/accumulo/manager/TabletGroupWatcher.java
index 215e0b8f74..52b398d98e 100644
--- 
a/server/manager/src/main/java/org/apache/accumulo/manager/TabletGroupWatcher.java
+++ 
b/server/manager/src/main/java/org/apache/accumulo/manager/TabletGroupWatcher.java
@@ -1065,10 +1065,14 @@ abstract class TabletGroupWatcher extends 
AccumuloDaemonThread {
     var deadLogs = tLists.logsForDeadServers;
 
     if (!deadTablets.isEmpty()) {
-      int maxServersToShow = min(deadTablets.size(), 100);
-      Manager.log.debug("{} assigned to dead servers: {}...", 
deadTablets.size(),
-          deadTablets.subList(0, maxServersToShow));
-      Manager.log.debug("logs for dead servers: {}", deadLogs);
+      Manager.log.debug("[{}] {} tablets assigned to dead servers", 
store.name(),
+          deadTablets.size());
+      if (Manager.log.isTraceEnabled()) {
+        deadLogs.forEach((server, logs) -> Manager.log.trace("[{}] dead 
server: {} logs: {}",
+            store.name(), server, logs));
+      } else {
+        Manager.log.debug("[{}] {} logs exist for dead servers", store.name(), 
deadLogs.size());
+      }
       if (canSuspendTablets()) {
         store.suspend(deadTablets, deadLogs, manager.getSteadyTime());
       } else {
@@ -1081,8 +1085,8 @@ abstract class TabletGroupWatcher extends 
AccumuloDaemonThread {
     }
     if (!tLists.suspendedToGoneServers.isEmpty()) {
       int maxServersToShow = min(deadTablets.size(), 100);
-      Manager.log.debug(deadTablets.size() + " suspended to gone servers: "
-          + deadTablets.subList(0, maxServersToShow) + "...");
+      Manager.log.debug("[{}] {} suspended to gone servers: {} ...", 
store.name(),
+          deadTablets.size(), deadTablets.subList(0, maxServersToShow));
       store.unsuspend(tLists.suspendedToGoneServers);
     }
   }