DRILL-7068: Support memory adjustment framework for resource management with Queues.

closes #1677

1 files changed, 2 insertions, 2 deletions

diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/work/user/PlanSplitter.java b/exec/java-exec/src/main/java/org/apache/drill/exec/work/user/PlanSplitter.java
index e789c1dfa..e61814ab3 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/work/user/PlanSplitter.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/work/user/PlanSplitter.java
@@ -113,7 +113,7 @@ public class PlanSplitter {
     final PhysicalOperator rootOperator = plan.getSortedOperators(false).iterator().next();
 
     final Fragment rootFragment = rootOperator.accept(MakeFragmentsVisitor.INSTANCE, null);
-    final SimpleParallelizer parallelizer = new SplittingParallelizer(queryContext);
+    final SimpleParallelizer parallelizer = new SplittingParallelizer(plan.getProperties().hasResourcePlan, queryContext);
 
     List<PlanFragment> fragments = Lists.newArrayList();
 
@@ -134,7 +134,7 @@ public class PlanSplitter {
         }
       }
     } else {
-      final QueryWorkUnit queryWorkUnit = parallelizer.getFragments(queryContext.getOptions().getOptionList(), queryContext.getCurrentEndpoint(),
+      final QueryWorkUnit queryWorkUnit = parallelizer.generateWorkUnit(queryContext.getOptions().getOptionList(), queryContext.getCurrentEndpoint(),
           queryId, queryContext.getActiveEndpoints(), rootFragment,
           queryContext.getSession(), queryContext.getQueryContextInfo());
       planner.visitPhysicalPlan(queryWorkUnit);