diff --git a/src/io/parquet/write/stream.rs b/src/io/parquet/write/stream.rs index d8165bc7f53..e9cb86c4bef 100644 --- a/src/io/parquet/write/stream.rs +++ b/src/io/parquet/write/stream.rs @@ -24,7 +24,7 @@ pub async fn write_stream<'a, W, I>( ) -> Result where W: std::io::Write, - I: Stream>>, + I: Stream>>, { let key_value_metadata = key_value_metadata .map(|mut x| { @@ -56,7 +56,7 @@ pub async fn write_stream_stream<'a, W, I>( ) -> Result where W: futures::io::AsyncWrite + Unpin + Send, - I: Stream>>, + I: Stream>>, { let key_value_metadata = key_value_metadata .map(|mut x| {