diff --git a/datafusion/optimizer/src/push_down_filter.rs b/datafusion/optimizer/src/push_down_filter.rs index bbf0b0dd810e..e75119ae0da3 100644 --- a/datafusion/optimizer/src/push_down_filter.rs +++ b/datafusion/optimizer/src/push_down_filter.rs @@ -940,7 +940,11 @@ impl OptimizerRule for PushDownFilter { let group_expr_columns = agg .group_expr .iter() - .map(|e| Ok(Column::from_qualified_name(e.schema_name().to_string()))) + .map(|e| { + Ok(Column::from_qualified_name_ignore_case( + e.schema_name().to_string(), + )) + }) .collect::>>()?; let predicates = split_conjunction_owned(filter.predicate);