Skip to content

Commit

Permalink
fix: FileStreamer's end should call writer flush to ensure parquet ma…
Browse files Browse the repository at this point in the history
…gic is flushed to file (#163)
  • Loading branch information
v0y4g3r authored Jul 26, 2022
1 parent 9d7f4d8 commit 450d05c
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions src/write/stream.rs
Original file line number Diff line number Diff line change
Expand Up @@ -41,6 +41,7 @@ async fn end_file<W: AsyncWrite + Unpin + Send>(

(&mut footer_buffer[4..]).write_all(&PARQUET_MAGIC)?;
writer.write_all(&footer_buffer).await?;
writer.flush().await?;
Ok(metadata_len as u64 + FOOTER_SIZE)
}

Expand Down

0 comments on commit 450d05c

Please sign in to comment.