From 9d63edb29939fe975c35b97fa7d45ca52c05ea9b Mon Sep 17 00:00:00 2001 From: Andrew Lamb Date: Tue, 13 Sep 2022 08:41:59 -0400 Subject: [PATCH] chore: remove unecessary batch check (#5620) Co-authored-by: kodiakhq[bot] <49736102+kodiakhq[bot]@users.noreply.github.com> --- parquet_file/src/serialize.rs | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) 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)?;