Shutdown parquet async writer (apache#4059)

tustvold · Apr 12, 2023 · 96569c1 · 96569c1
1 parent ee40033
commit 96569c1
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/parquet/src/arrow/async_writer/mod.rs b/parquet/src/arrow/async_writer/mod.rs
@@ -129,6 +129,7 @@ impl<W: AsyncWrite + Unpin + Send> AsyncArrowWriter<W> {
 
         // Force to flush the remaining data.
         Self::try_flush(&mut self.shared_buffer, &mut self.async_writer, true).await?;
+        self.async_writer.shutdown().await?;
 
         Ok(metadata)
     }