Skip to content

Commit 6962d1b

Browse files
committed
Fix unboundedness opt
1 parent 2db642f commit 6962d1b

File tree

4 files changed

+5
-4
lines changed

4 files changed

+5
-4
lines changed

datafusion/core/tests/physical_optimizer/sanity_checker.rs

+1-1
Original file line numberDiff line numberDiff line change
@@ -147,7 +147,7 @@ impl QueryCase {
147147
error.as_str()
148148
);
149149
} else {
150-
assert!(plan.is_ok())
150+
assert!(plan.is_ok(), "plan: {:?} should be ok", plan);
151151
}
152152
Ok(())
153153
}

datafusion/physical-optimizer/src/join_selection.rs

+2-1
Original file line numberDiff line numberDiff line change
@@ -571,7 +571,8 @@ pub(crate) fn swap_join_according_to_unboundedness(
571571
hash_join.swap_inputs(PartitionMode::CollectLeft)
572572
}
573573
(PartitionMode::Auto, _) => {
574-
internal_err!("Auto is not acceptable for unbounded input here.")
574+
// Default to Partitioned mode, so it won't be swapped again
575+
hash_join.swap_inputs(PartitionMode::Partitioned)
575576
}
576577
}
577578
}

0 commit comments

Comments
 (0)