Skip to content

Commit 0942f30

Browse files
authored
set scan executor names for meta and root (#5987)
1 parent b29f014 commit 0942f30

1 file changed

Lines changed: 8 additions & 3 deletions

File tree

server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServerResourceManager.java

Lines changed: 8 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -787,19 +787,24 @@ private static abstract class DispatchParamsImpl implements DispatchParameters,
787787

788788
}
789789

790+
private static final ScanDispatch ROOT_SCAN_DISPATCH =
791+
ScanDispatch.builder().setExecutorName("root").build();
792+
private static final ScanDispatch META_SCAN_DISPATCH =
793+
ScanDispatch.builder().setExecutorName("meta").build();
794+
790795
public void executeReadAhead(KeyExtent tablet, ScanDispatcher dispatcher, ScanSession<?> scanInfo,
791796
Runnable task) {
792797

793798
task = ScanSession.wrap(scanInfo, task);
794799

795800
if (tablet.isRootTablet()) {
796801
// TODO make meta dispatch??
797-
scanInfo.scanParams.setScanDispatch(ScanDispatch.builder().build());
802+
scanInfo.scanParams.setScanDispatch(ROOT_SCAN_DISPATCH);
798803
task.run();
799804
} else if (tablet.isMeta()) {
800805
// TODO make meta dispatch??
801-
scanInfo.scanParams.setScanDispatch(ScanDispatch.builder().build());
802-
scanExecutors.get("meta").execute(task);
806+
scanInfo.scanParams.setScanDispatch(META_SCAN_DISPATCH);
807+
scanExecutors.get(META_SCAN_DISPATCH.getExecutorName()).execute(task);
803808
} else {
804809
DispatchParameters params = new DispatchParamsImpl() {
805810

0 commit comments

Comments
 (0)