diff --git a/datafusion/physical-plan/src/aggregates/mod.rs b/datafusion/physical-plan/src/aggregates/mod.rs index 2e0103defd9f..36c6d173bd6c 100644 --- a/datafusion/physical-plan/src/aggregates/mod.rs +++ b/datafusion/physical-plan/src/aggregates/mod.rs @@ -792,6 +792,11 @@ impl ExecutionPlan for AggregateExec { vec![self.required_input_ordering.clone()] } + fn maintains_input_order(&self) -> Vec { + // See: InputOrderMode documentation for aggregations + vec![self.input_order_mode != InputOrderMode::Linear] + } + fn children(&self) -> Vec<&Arc> { vec![&self.input] }