Skip to content

Commit

Permalink
fix: Incorrect input schema when preparing result expressions for Has…
Browse files Browse the repository at this point in the history
…hAggregation (#501)
  • Loading branch information
viirya authored Jun 1, 2024
1 parent 6ea5a42 commit 24781fb
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion core/src/execution/datafusion/planner.rs
Original file line number Diff line number Diff line change
Expand Up @@ -779,7 +779,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();
Expand Down

0 comments on commit 24781fb

Please sign in to comment.