diff --git a/datafusion/expr/src/utils.rs b/datafusion/expr/src/utils.rs index 3111579246f2..10528e07fbaa 100644 --- a/datafusion/expr/src/utils.rs +++ b/datafusion/expr/src/utils.rs @@ -833,14 +833,13 @@ pub fn from_plan( window_expr: expr[0..window_expr.len()].to_vec(), schema: schema.clone(), })), - LogicalPlan::Aggregate(Aggregate { - group_expr, schema, .. - }) => Ok(LogicalPlan::Aggregate(Aggregate::try_new_with_schema( - Arc::new(inputs[0].clone()), - expr[0..group_expr.len()].to_vec(), - expr[group_expr.len()..].to_vec(), - schema.clone(), - )?)), + LogicalPlan::Aggregate(Aggregate { group_expr, .. }) => { + Ok(LogicalPlan::Aggregate(Aggregate::try_new( + Arc::new(inputs[0].clone()), + expr[0..group_expr.len()].to_vec(), + expr[group_expr.len()..].to_vec(), + )?)) + } LogicalPlan::Sort(SortPlan { fetch, .. }) => Ok(LogicalPlan::Sort(SortPlan { expr: expr.to_vec(), input: Arc::new(inputs[0].clone()),