File tree Expand file tree Collapse file tree 2 files changed +1
-10
lines changed
x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/planner Expand file tree Collapse file tree 2 files changed +1
-10
lines changed Original file line number Diff line number Diff line change 3333import org .elasticsearch .xpack .esql .expression .function .aggregate .Count ;
3434import org .elasticsearch .xpack .esql .expression .function .grouping .Categorize ;
3535import org .elasticsearch .xpack .esql .plan .physical .AggregateExec ;
36- import org .elasticsearch .xpack .esql .plan .physical .ExchangeSourceExec ;
3736import org .elasticsearch .xpack .esql .plan .physical .TimeSeriesAggregateExec ;
3837import org .elasticsearch .xpack .esql .planner .LocalExecutionPlanner .LocalExecutionPlannerContext ;
3938import org .elasticsearch .xpack .esql .planner .LocalExecutionPlanner .PhysicalOperation ;
@@ -71,14 +70,6 @@ public final PhysicalOperation groupingPhysicalOperation(
7170
7271 var sourceLayout = source .layout ;
7372
74- if (aggregatorMode != AggregatorMode .INITIAL && aggregatorMode != AggregatorMode .FINAL ) {
75- assert false : "Invalid aggregator mode [" + aggregatorMode + "]" ;
76- }
77- if (aggregatorMode == AggregatorMode .INITIAL && aggregateExec .child () instanceof ExchangeSourceExec ) {
78- // the reducer step at data node (local) level
79- aggregatorMode = AggregatorMode .INTERMEDIATE ;
80- }
81-
8273 if (aggregateExec .groupings ().isEmpty ()) {
8374 // not grouping
8475 List <Aggregator .Factory > aggregatorFactories = new ArrayList <>();
Original file line number Diff line number Diff line change @@ -124,7 +124,7 @@ public static PhysicalPlan reductionPlan(PhysicalPlan plan) {
124124 final LocalMapper mapper = new LocalMapper ();
125125 PhysicalPlan reducePlan = mapper .map (pipelineBreaker );
126126 if (reducePlan instanceof AggregateExec agg ) {
127- reducePlan = agg .withMode (AggregatorMode .INITIAL ); // force to emit intermediate outputs
127+ reducePlan = agg .withMode (AggregatorMode .INTERMEDIATE );
128128 }
129129 return EstimatesRowSize .estimateRowSize (fragment .estimatedRowSize (), reducePlan );
130130 }
You can’t perform that action at this time.
0 commit comments