diff --git a/src/datatypes/src/series/frame.rs b/src/datatypes/src/series/frame.rs index 27902ecf805..da6ff38d1ae 100644 --- a/src/datatypes/src/series/frame.rs +++ b/src/datatypes/src/series/frame.rs @@ -303,10 +303,10 @@ impl RawSeriesChunkCursor { return Ok(Some(batch)); } builder.push(row)?; - if builder.is_full() { - if let Some(batch) = builder.flush()? { - return Ok(Some(batch)); - } + if builder.is_full() + && let Some(batch) = builder.flush()? + { + return Ok(Some(batch)); } } }