diff --git a/core/vdbe/sorter.rs b/core/vdbe/sorter.rs index 49d486810..d3e7c6b0d 100644 --- a/core/vdbe/sorter.rs +++ b/core/vdbe/sorter.rs @@ -149,7 +149,7 @@ impl Sorter { // Write complete, we can now read from the chunk. chunk.read()?; } - SortedChunkIOState::WaitingForWrite => { + SortedChunkIOState::WaitingForWrite | SortedChunkIOState::WaitingForRead => { all_read_complete = false; } SortedChunkIOState::ReadEOF | SortedChunkIOState::ReadComplete => {}