Skip to content

Commit 3314b1c

Browse files
committed
Adjust formatting
1 parent 4f1131e commit 3314b1c

1 file changed

Lines changed: 4 additions & 1 deletion

File tree

datafusion/physical-plan/src/spill/spill_pool.rs

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -538,7 +538,10 @@ impl Stream for SpillFile {
538538
if self.reader.is_none() && should_read {
539539
if let Some(file) = file {
540540
// we want this unbuffered because files are actively being written to
541-
match self.spill_manager.read_spill_as_stream_unbuffered(file, None) {
541+
match self
542+
.spill_manager
543+
.read_spill_as_stream_unbuffered(file, None)
544+
{
542545
Ok(stream) => {
543546
self.reader = Some(SpillFileReader {
544547
stream,

0 commit comments

Comments
 (0)