Skip to content

Commit da6be6f

Browse files
authored
(cherry-pick) fix: Check maintains_input_order in EnforceDistribution (#35) (#37)
1 parent 795aa28 commit da6be6f

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

datafusion/physical-optimizer/src/enforce_distribution.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1472,7 +1472,7 @@ pub fn ensure_distribution(
14721472
&plan,
14731473
&child.plan,
14741474
);
1475-
if !streaming_benefit {
1475+
if !streaming_benefit && !maintains {
14761476
child =
14771477
replace_order_preserving_variants(child, false)?.0;
14781478
}

0 commit comments

Comments
 (0)