[arrow-rs] branch master updated: Shutdown parquet async writer (#4059)

[tustvold]

This is an automated email from the ASF dual-hosted git repository.

tustvold pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/arrow-rs.git


The following commit(s) were added to refs/heads/master by this push:
     new 96569c1e9 Shutdown parquet async writer (#4059)
96569c1e9 is described below

commit 96569c1e9cf89cf4bdb0d9bf6bc30387a3e3555b
Author: kindly <david.razn...@opendataservices.coop>
AuthorDate: Wed Apr 12 04:44:25 2023 +0100

    Shutdown parquet async writer (#4059)
---
 parquet/src/arrow/async_writer/mod.rs | 1 +
 1 file changed, 1 insertion(+)

diff --git a/parquet/src/arrow/async_writer/mod.rs 
b/parquet/src/arrow/async_writer/mod.rs
index abfb1c54e..339618364 100644
--- 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)
     }