diff options
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/work/user/PlanSplitter.java')
-rw-r--r-- | exec/java-exec/src/main/java/org/apache/drill/exec/work/user/PlanSplitter.java | 4 |
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); |