lint

Author: mattcuento

ballista/core/src/execution_plans/sort_shuffle/writer.rs

@@ -357,8 +357,12 @@ fn spill_all_partitions(
         if indices.is_empty() {
             continue;
         }
-        let batches =
-            materialize_partition(indices, input_store, batch_size, &mut scratch_builder)?;
+        let batches = materialize_partition(
+            indices,
+            input_store,
+            batch_size,
+            &mut scratch_builder,
+        )?;
         if !batches.is_empty() {
             spill_manager
                 .spill(partition_id, batches, schema)

benchmarks/src/bin/shuffle_bench.rs

@@ -337,7 +337,9 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
         {
             let temp_dir = TempDir::new()?;
             let work_dir = temp_dir.path().to_str().unwrap();
-            let _ = benchmark_hash_shuffle(&data, schema.clone(), opt.partitions, work_dir).await?;
+            let _ =
+                benchmark_hash_shuffle(&data, schema.clone(), opt.partitions, work_dir)
+                    .await?;
             println!("  Warmup iteration completed (not timed)");
         }