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<? 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;