Skip to content

Commit

Permalink
Update datafusion/physical-plan/src/joins/sort_merge_join.rs
Browse files Browse the repository at this point in the history
Co-authored-by: Oleks V <[email protected]>
  • Loading branch information
viirya and comphead authored Jun 13, 2024
1 parent 22e4692 commit f81c488
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion datafusion/physical-plan/src/joins/sort_merge_join.rs
Original file line number Diff line number Diff line change
Expand Up @@ -1363,7 +1363,7 @@ impl SMJStream {
// Usually this is done by `freeze_buffered`. However, if a buffered row is joined with
// streamed side, it won't be outputted by `freeze_buffered`.
// We need to check if a buffered row is joined with streamed side and output.
// If it is joined with streamed side, but finally fails on the join filter,
// If it is joined with streamed side, but doesn't match the join filter,
// we need to output it with nulls as streamed side.
if matches!(self.join_type, JoinType::Full) {
for i in 0..pre_mask.len() {
Expand Down

0 comments on commit f81c488

Please sign in to comment.