Update datafusion/physical-plan/src/joins/sort_merge_join.rs

Co-authored-by: Oleks V <[email protected]>
viirya · Jun 13, 2024 · b5ef137 · b5ef137
1 parent f81c488
commit b5ef137
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/datafusion/physical-plan/src/joins/sort_merge_join.rs b/datafusion/physical-plan/src/joins/sort_merge_join.rs
@@ -1372,7 +1372,7 @@ impl SMJStream {
                                 let buffered_index = buffered_indices.value(i);
 
                                 if !pre_mask.value(i) {
-                                    // For a buffered row that is joined with streamed side but failed on the join filter,
+                                    // For a buffered row that is joined with streamed side but doesn't satisfy the join filter,
                                     buffered_batch
                                         .join_filter_failed_idxs
                                         .insert(buffered_index);