Skip to content

Commit

Permalink
Fix build
Browse files Browse the repository at this point in the history
  • Loading branch information
jonahgao committed Jan 2, 2025
1 parent eee3a93 commit 3830c57
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 8 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().iter(),
plan.required_input_ordering().into_iter(),
plan.maintains_input_order(),
repartition_status_flags.into_iter()
)
Expand Down Expand Up @@ -1275,7 +1275,7 @@ fn ensure_distribution(
let ordering_satisfied = child
.plan
.equivalence_properties()
.ordering_satisfy_requirement(required_input_ordering);
.ordering_satisfy_requirement(&required_input_ordering);
if (!ordering_satisfied || !order_preserving_variants_desirable)
&& child.data
{
Expand Down
12 changes: 6 additions & 6 deletions datafusion/core/src/physical_optimizer/sanity_checker.rs
Original file line number Diff line number Diff line change
Expand Up @@ -131,18 +131,18 @@ pub fn check_plan_sanity(
check_finiteness_requirements(Arc::clone(&plan), optimizer_options)?;

for ((idx, child), sort_req, dist_req) in izip!(
plan.children().iter().enumerate(),
plan.required_input_ordering().iter(),
plan.required_input_distribution().iter()
plan.children().into_iter().enumerate(),
plan.required_input_ordering().into_iter(),
plan.required_input_distribution().into_iter()
) {
let child_eq_props = child.equivalence_properties();
if let Some(sort_req) = sort_req {
if !child_eq_props.ordering_satisfy_requirement(sort_req) {
if !child_eq_props.ordering_satisfy_requirement(&sort_req) {
let plan_str = get_plan_string(&plan);
return plan_err!(
"Plan: {:?} does not satisfy order requirements: {}. Child-{} order: {}",
plan_str,
format_physical_sort_requirement_list(sort_req),
format_physical_sort_requirement_list(&sort_req),
idx,
child_eq_props.oeq_class
);
Expand All @@ -151,7 +151,7 @@ pub fn check_plan_sanity(

if !child
.output_partitioning()
.satisfy(dist_req, child_eq_props)
.satisfy(&dist_req, child_eq_props)
{
let plan_str = get_plan_string(&plan);
return plan_err!(
Expand Down

0 comments on commit 3830c57

Please sign in to comment.