Skip to content

Commit

Permalink
Simplify
Browse files Browse the repository at this point in the history
  • Loading branch information
jonahgao committed Jan 2, 2025
1 parent 3830c57 commit 53197f0
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -1208,7 +1208,7 @@ fn ensure_distribution(
// We store the updated children in `new_children`.
let children = izip!(
children.into_iter(),
plan.required_input_ordering().into_iter(),
plan.required_input_ordering(),
plan.maintains_input_order(),
repartition_status_flags.into_iter()
)
Expand Down
4 changes: 2 additions & 2 deletions datafusion/core/src/physical_optimizer/sanity_checker.rs
Original file line number Diff line number Diff line change
Expand Up @@ -132,8 +132,8 @@ pub fn check_plan_sanity(

for ((idx, child), sort_req, dist_req) in izip!(
plan.children().into_iter().enumerate(),
plan.required_input_ordering().into_iter(),
plan.required_input_distribution().into_iter()
plan.required_input_ordering(),
plan.required_input_distribution(),
) {
let child_eq_props = child.equivalence_properties();
if let Some(sort_req) = sort_req {
Expand Down

0 comments on commit 53197f0

Please sign in to comment.