diff --git a/datafusion/physical-plan/src/joins/sort_merge_join.rs b/datafusion/physical-plan/src/joins/sort_merge_join.rs index 70fd682ee911..933e1b4b1447 100644 --- a/datafusion/physical-plan/src/joins/sort_merge_join.rs +++ b/datafusion/physical-plan/src/joins/sort_merge_join.rs @@ -1064,7 +1064,7 @@ impl SMJStream { Some(scanning_idx), ); } else { - // Join nulls and buffered row for full join + // Join nulls and buffered row for FULL join self.buffered_data .scanning_batch_mut() .null_joined