From 96569c1e9cf89cf4bdb0d9bf6bc30387a3e3555b Mon Sep 17 00:00:00 2001
From: kindly <david.raznick@opendataservices.coop>
Date: Wed, 12 Apr 2023 04:44:25 +0100
Subject: [PATCH] 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 abfb1c54ed44..339618364324 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)
     }