From eaa70a8fa73eb3211da00b59b47538857028c347 Mon Sep 17 00:00:00 2001 From: Keith Turner Date: Thu, 20 Nov 2025 20:45:13 +0000 Subject: [PATCH] set scan executor names for meta and root --- .../accumulo/tserver/TabletServerResourceManager.java | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) diff --git a/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServerResourceManager.java b/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServerResourceManager.java index 1fdfcffda4a..748d74705bd 100644 --- a/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServerResourceManager.java +++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServerResourceManager.java @@ -787,6 +787,11 @@ private static abstract class DispatchParamsImpl implements DispatchParameters, } + private static final ScanDispatch ROOT_SCAN_DISPATCH = + ScanDispatch.builder().setExecutorName("root").build(); + private static final ScanDispatch META_SCAN_DISPATCH = + ScanDispatch.builder().setExecutorName("meta").build(); + public void executeReadAhead(KeyExtent tablet, ScanDispatcher dispatcher, ScanSession scanInfo, Runnable task) { @@ -794,12 +799,12 @@ public void executeReadAhead(KeyExtent tablet, ScanDispatcher dispatcher, ScanSe if (tablet.isRootTablet()) { // TODO make meta dispatch?? - scanInfo.scanParams.setScanDispatch(ScanDispatch.builder().build()); + scanInfo.scanParams.setScanDispatch(ROOT_SCAN_DISPATCH); task.run(); } else if (tablet.isMeta()) { // TODO make meta dispatch?? - scanInfo.scanParams.setScanDispatch(ScanDispatch.builder().build()); - scanExecutors.get("meta").execute(task); + scanInfo.scanParams.setScanDispatch(META_SCAN_DISPATCH); + scanExecutors.get(META_SCAN_DISPATCH.getExecutorName()).execute(task); } else { DispatchParameters params = new DispatchParamsImpl() {