We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 2a81385 commit 1edf536Copy full SHA for 1edf536
1 file changed
datafusion/physical-plan/src/joins/hash_join/shared_bounds.rs
@@ -646,7 +646,9 @@ impl SharedBuildAccumulator {
646
}
647
} else if real_branches.is_empty() {
648
lit(false)
649
- } else if num_partitions == 1 {
+ } else if real_branches.len() == 1
650
+ && empty_partition_ids.len() + 1 == num_partitions
651
+ {
652
Arc::clone(&real_branches[0].1)
653
} else {
654
Arc::new(CaseExpr::try_new(
0 commit comments