Skip to content

Commit

Permalink
Enable debugging for shard ranges (#2565)
Browse files Browse the repository at this point in the history
  • Loading branch information
apmoriarty authored Sep 18, 2024
1 parent 8db4eae commit 01f87de
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -199,7 +199,7 @@ public Scan call() throws Exception {
Class<? extends AccumuloResource> initializer = delegatedResourceInitializer;

boolean docSpecific = RangeDefinition.isDocSpecific(currentRange);
if (!docSpecific && !initializer.isInstance(RfileResource.class)) {
if (!docSpecific && !initializer.isAssignableFrom(RfileResource.class)) {
// this catches the case where a scanner was created with a RunningResource and a shard range was generated
// when bypassing accumulo with a RFileResource, do not override the initializer with a BatchResource
initializer = BatchResource.class;
Expand Down

0 comments on commit 01f87de

Please sign in to comment.