You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@arrow.apache.org by dh...@apache.org on 2023/07/13 08:54:05 UTC
[arrow-datafusion] branch fix_single_required_partitioning created (now aa8933d324)
This is an automated email from the ASF dual-hosted git repository.
dheres pushed a change to branch fix_single_required_partitioning
in repository https://gitbox.apache.org/repos/asf/arrow-datafusion.git
at aa8933d324 Fix required partitioning of Single aggregation mode
This branch includes the following new commits:
new aa8933d324 Fix required partitioning of Single aggregation mode
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[arrow-datafusion] 01/01: Fix required partitioning of Single aggregation mode
Posted by dh...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
dheres pushed a commit to branch fix_single_required_partitioning
in repository https://gitbox.apache.org/repos/asf/arrow-datafusion.git
commit aa8933d324debc85bf5ba060d164753bb9015b80
Author: Daniël Heres <da...@coralogix.com>
AuthorDate: Thu Jul 13 10:53:54 2023 +0200
Fix required partitioning of Single aggregation mode
---
datafusion/core/src/physical_plan/aggregates/mod.rs | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/datafusion/core/src/physical_plan/aggregates/mod.rs b/datafusion/core/src/physical_plan/aggregates/mod.rs
index 60d483d8c8..0bb76a857b 100644
--- a/datafusion/core/src/physical_plan/aggregates/mod.rs
+++ b/datafusion/core/src/physical_plan/aggregates/mod.rs
@@ -872,10 +872,10 @@ impl ExecutionPlan for AggregateExec {
fn required_input_distribution(&self) -> Vec<Distribution> {
match &self.mode {
- AggregateMode::Partial | AggregateMode::Single => {
+ AggregateMode::Partial => {
vec![Distribution::UnspecifiedDistribution]
}
- AggregateMode::FinalPartitioned => {
+ AggregateMode::FinalPartitioned | AggregateMode::Single => {
vec![Distribution::HashPartitioned(self.output_group_expr())]
}
AggregateMode::Final => vec![Distribution::SinglePartition],