Skip to content

Commit

Permalink
Merge branch 'repartition_poc_2' of github.com:Dandandan/arrow-datafu…
Browse files Browse the repository at this point in the history
…sion into repartition_poc_2
  • Loading branch information
Dandandan committed Dec 10, 2024
2 parents a8c8ae3 + a10d8ab commit f4f5902
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -837,7 +837,7 @@ fn add_roundrobin_on_top(
) -> Result<DistributionContext> {
// Adding repartition is helpful:
if input.plan.output_partitioning().partition_count() < n_target
|| input.plan.children().is_empty()
|| (input.plan.children().is_empty() && input.plan.output_partitioning().partition_count() > 1)
{
// When there is an existing ordering, we preserve ordering
// during repartition. This will be un-done in the future
Expand Down

0 comments on commit f4f5902

Please sign in to comment.