diff --git a/datafusion/physical-plan/src/repartition/mod.rs b/datafusion/physical-plan/src/repartition/mod.rs index 1a4bb797c5f1..5b25d582d20c 100644 --- a/datafusion/physical-plan/src/repartition/mod.rs +++ b/datafusion/physical-plan/src/repartition/mod.rs @@ -299,8 +299,7 @@ impl BatchPartitioner { let _timer = partitioner_timer.timer(); // Produce batches based on indices - let columns = - take_arrays(batch.columns(), &indices)?; + let columns = take_arrays(batch.columns(), &indices)?; let mut options = RecordBatchOptions::new(); options = options.with_row_count(Some(indices.len()));