This is an automated email from the ASF dual-hosted git repository.
kturner 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 0942f30ed5 set scan executor names for meta and root (#5987)
0942f30ed5 is described below
commit 0942f30ed5aa85b12110019934f522f163b53cd6
Author: Keith Turner <[email protected]>
AuthorDate: Fri Nov 21 15:20:00 2025 -0500
set scan executor names for meta and root (#5987)
---
.../apache/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 1fdfcffda4..748d74705b 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 @@ public class TabletServerResourceManager {
}
+ 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 class TabletServerResourceManager {
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() {