From b5ef13709c8c62f67be8f2bfda872189ed0ac27e Mon Sep 17 00:00:00 2001 From: Liang-Chi Hsieh Date: Thu, 13 Jun 2024 10:56:11 -0700 Subject: [PATCH] Update datafusion/physical-plan/src/joins/sort_merge_join.rs Co-authored-by: Oleks V --- datafusion/physical-plan/src/joins/sort_merge_join.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/datafusion/physical-plan/src/joins/sort_merge_join.rs b/datafusion/physical-plan/src/joins/sort_merge_join.rs index 7bbd4a54d102..70fd682ee911 100644 --- 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);