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