fix bug

apache · Apr 1, 2024 · e4e1c38 · e4e1c38
1 parent 86d0faf
commit e4e1c38
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/datafusion/physical-plan/src/coalesce_batches.rs b/datafusion/physical-plan/src/coalesce_batches.rs
@@ -240,7 +240,7 @@ impl CoalesceBatchesStream {
                     Some(Ok(batch)) => {
                         if (batch.num_rows() >= self.target_batch_size
                             || batch.num_rows() >= self.fetch)
-                            || self.buffer.is_empty()
+                            && self.buffer.is_empty()
                         {
                             return Poll::Ready(Some(Ok(batch)));
                         } else if batch.num_rows() == 0 {