diff --git a/datafusion/physical-plan/src/joins/sort_merge_join.rs b/datafusion/physical-plan/src/joins/sort_merge_join.rs index b751ccbc94b0..a3930faf972a 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 as u64), + buffered_indices.iter().map(|&index| index), ); if let Some(record_batch) = produce_buffered_null_batch(