format

andygrove · Dec 27, 2024 · 45b020e · 45b020e
1 parent f1ed927
commit 45b020e
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/native/core/src/execution/shuffle/shuffle_writer.rs b/native/core/src/execution/shuffle/shuffle_writer.rs
@@ -351,7 +351,12 @@ impl PartitionBuffer {
         let frozen_capacity_old = self.frozen.capacity();
         let mut cursor = Cursor::new(&mut self.frozen);
         cursor.seek(SeekFrom::End(0))?;
-        write_ipc_compressed(&frozen_batch, &mut cursor, &self.codec, &metrics.encode_time)?;
+        write_ipc_compressed(
+            &frozen_batch,
+            &mut cursor,
+            &self.codec,
+            &metrics.encode_time,
+        )?;
 
         mem_diff += (self.frozen.capacity() - frozen_capacity_old) as isize;
         Ok(mem_diff)
@@ -1042,7 +1047,6 @@ impl ShuffleRepartitioner {
             &self.metrics,
         )?;
 
-
         let mut spills = self.spills.lock().await;
         let used = self.reservation.size();
         self.metrics.spill_count.add(1);