diff --git a/src/write/stream.rs b/src/write/stream.rs
index 6dae94cea..13d0668ea 100644
--- a/src/write/stream.rs
+++ b/src/write/stream.rs
@@ -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)
 }