We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 4f1131e commit 3314b1cCopy full SHA for 3314b1c
1 file changed
datafusion/physical-plan/src/spill/spill_pool.rs
@@ -538,7 +538,10 @@ impl Stream for SpillFile {
538
if self.reader.is_none() && should_read {
539
if let Some(file) = file {
540
// we want this unbuffered because files are actively being written to
541
- match self.spill_manager.read_spill_as_stream_unbuffered(file, None) {
+ match self
542
+ .spill_manager
543
+ .read_spill_as_stream_unbuffered(file, None)
544
+ {
545
Ok(stream) => {
546
self.reader = Some(SpillFileReader {
547
stream,
0 commit comments