Skip to content

Commit

Permalink
format
Browse files Browse the repository at this point in the history
  • Loading branch information
andygrove committed Dec 23, 2024
1 parent 4ffe47d commit 68d2331
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions native/core/src/execution/shuffle/shuffle_writer.rs
Original file line number Diff line number Diff line change
Expand Up @@ -68,7 +68,6 @@ use std::{
};
use tokio::time::Instant;


/// The status of appending rows to a partition buffer.
enum AppendRowStatus {
/// The difference in memory usage after appending rows
Expand Down Expand Up @@ -1611,7 +1610,9 @@ pub fn read_ipc_compressed(bytes: &[u8]) -> Result<RecordBatch> {
if let Some(batch) = reader.next() {
batch.map_err(|e| e.into())
} else {
Err(DataFusionError::Execution("Failed to decode batch".to_string()))
Err(DataFusionError::Execution(
"Failed to decode batch".to_string(),
))
}
}

Expand Down

0 comments on commit 68d2331

Please sign in to comment.