(accumulo) branch 2.1 updated: Adds number of scanner threads to log message (#5964)

[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 ef6c43788d Adds number of scanner threads to log message (#5964)
ef6c43788d is described below

commit ef6c43788da51bb4155aa493ae75cc744c989712
Author: Daniel Roberts <ddani...@gmail.com>
AuthorDate: Wed Oct 29 13:32:21 2025 -0400

    Adds number of scanner threads to log message (#5964)
    
    Adds the number of scanner threads configured for the
    MetaDataTableScanner to the debug log message.
---
 .../server/manager/state/MetaDataTableScanner.java         | 14 ++++++++++----
 1 file changed, 10 insertions(+), 4 deletions(-)

diff --git 
a/server/base/src/main/java/org/apache/accumulo/server/manager/state/MetaDataTableScanner.java
 
b/server/base/src/main/java/org/apache/accumulo/server/manager/state/MetaDataTableScanner.java
index c97f32926d..f0f2a3651a 100644
--- 
a/server/base/src/main/java/org/apache/accumulo/server/manager/state/MetaDataTableScanner.java
+++ 
b/server/base/src/main/java/org/apache/accumulo/server/manager/state/MetaDataTableScanner.java
@@ -76,21 +76,27 @@ public class MetaDataTableScanner implements 
ClosableIterator<TabletLocationStat
     // scan over metadata table, looking for tablets in the wrong state based 
on the live servers
     // and online tables
     String tableName = level.metaTable();
+    int numThreads;
     try {
-      var numThreads =
+      numThreads =
           
context.getConfiguration().getCount(Property.MANAGER_TABLET_GROUP_WATCHER_SCAN_THREADS);
       mdScanner = context.createBatchScanner(tableName, Authorizations.EMPTY, 
numThreads);
     } catch (TableNotFoundException e) {
       throw new IllegalStateException("Metadata table " + tableName + " should 
exist", e);
     }
     cleanable = CleanerUtil.unclosed(this, MetaDataTableScanner.class, closed, 
log, mdScanner);
-    configureScanner(context.getConfiguration(), mdScanner, state, level);
+    configureScanner(context.getConfiguration(), mdScanner, state, level, 
numThreads);
     mdScanner.setRanges(Collections.singletonList(range));
     iter = mdScanner.iterator();
   }
 
   public static void configureScanner(AccumuloConfiguration aconf, ScannerBase 
scanner,
       CurrentState state, DataLevel dataLevel) {
+    configureScanner(aconf, scanner, state, dataLevel, 1);
+  }
+
+  public static void configureScanner(AccumuloConfiguration aconf, ScannerBase 
scanner,
+      CurrentState state, DataLevel dataLevel, int numThreads) {
     TabletColumnFamily.PREV_ROW_COLUMN.fetch(scanner);
     scanner.fetchColumnFamily(CurrentLocationColumnFamily.NAME);
     scanner.fetchColumnFamily(FutureLocationColumnFamily.NAME);
@@ -113,11 +119,11 @@ public class MetaDataTableScanner implements 
ClosableIterator<TabletLocationStat
       TabletStateChangeIterator.setManagerState(tabletChange, 
state.getManagerState());
       TabletStateChangeIterator.setShuttingDown(aconf, tabletChange, 
state.shutdownServers());
       log.debug(
-          "{} configured meta scanner opts, online servers:{} tables:{} 
migrations:{} options_size:{} create_time:{}ms",
+          "{} configured meta scanner opts, online servers:{} tables:{} 
migrations:{} options_size:{} scanner threads:{} create_time:{}ms",
           dataLevel, servers.size(), tables.size(), migrations.size(),
           tabletChange.getOptions().entrySet().stream()
               .mapToLong(e -> e.getKey().length() + 
e.getValue().length()).sum(),
-          timer.elapsed(TimeUnit.MILLISECONDS));
+          numThreads, timer.elapsed(TimeUnit.MILLISECONDS));
     }
     scanner.addScanIterator(tabletChange);
   }