This is an automated email from the ASF dual-hosted git repository.
viirya pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/datafusion-comet.git
The following commit(s) were added to refs/heads/main by this push:
new 24781fb7 fix: Incorrect input schema when preparing result expressions
for HashAggregation (#501)
24781fb7 is described below
commit 24781fb7b3966f787cf72c97f42e2613f24fb2ac
Author: Liang-Chi Hsieh <[email protected]>
AuthorDate: Sat Jun 1 14:05:24 2024 -0700
fix: Incorrect input schema when preparing result expressions for
HashAggregation (#501)
---
core/src/execution/datafusion/planner.rs | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/core/src/execution/datafusion/planner.rs
b/core/src/execution/datafusion/planner.rs
index 7a37e3aa..a0b75de3 100644
--- a/core/src/execution/datafusion/planner.rs
+++ b/core/src/execution/datafusion/planner.rs
@@ -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();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
