diff --git a/datafusion/physical-plan/src/joins/sort_merge_join.rs b/datafusion/physical-plan/src/joins/sort_merge_join.rs index a3930faf972a..182d49d8e692 100644 --- a/datafusion/physical-plan/src/joins/sort_merge_join.rs +++ b/datafusion/physical-plan/src/joins/sort_merge_join.rs @@ -1239,7 +1239,7 @@ impl SMJStream { .collect::>(); let buffered_indices = UInt64Array::from_iter_values( - buffered_indices.iter().map(|&index| index), + buffered_indices.iter().copied(), ); if let Some(record_batch) = produce_buffered_null_batch(