Fix

viirya · Jun 1, 2024 · 3c7452f · 3c7452f
1 parent 4b320e3
commit 3c7452f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/core/src/execution/datafusion/planner.rs b/core/src/execution/datafusion/planner.rs
@@ -773,7 +773,7 @@ impl PhysicalPlanner {
                     .iter()
                     .enumerate()
                     .map(|(idx, expr)| {
-                        self.create_expr(expr, child.schema())
+                        self.create_expr(expr, aggregate.schema())
                             .map(|r| (r, format!("col_{}", idx)))
                     })
                     .collect();