diff --git a/parquet_file/src/serialize.rs b/parquet_file/src/serialize.rs index 656082d2a5..0147b7e04d 100644 --- a/parquet_file/src/serialize.rs +++ b/parquet_file/src/serialize.rs @@ -118,9 +118,7 @@ where while let Some(maybe_batch) = stream.next().await { let batch = maybe_batch?; - if batch.num_rows() != 0 { - writer.write(&batch)?; - } + writer.write(&batch)?; } let meta = writer.close().map_err(CodecError::from)?;