From 01f87decca953ec7882e2759fcf1eb500d6e1252 Mon Sep 17 00:00:00 2001 From: Moriarty <22225248+apmoriarty@users.noreply.github.com> Date: Wed, 18 Sep 2024 10:17:02 -0400 Subject: [PATCH] Enable debugging for shard ranges (#2565) --- .../src/main/java/datawave/query/tables/async/Scan.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/warehouse/query-core/src/main/java/datawave/query/tables/async/Scan.java b/warehouse/query-core/src/main/java/datawave/query/tables/async/Scan.java index 2ff0b11e2b1..c3f991301ab 100644 --- a/warehouse/query-core/src/main/java/datawave/query/tables/async/Scan.java +++ b/warehouse/query-core/src/main/java/datawave/query/tables/async/Scan.java @@ -199,7 +199,7 @@ public Scan call() throws Exception { Class 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;