diff --git a/parquet/src/arrow/async_reader.rs b/parquet/src/arrow/async_reader.rs index c9040bf12b93..03d231f41b0f 100644 --- a/parquet/src/arrow/async_reader.rs +++ b/parquet/src/arrow/async_reader.rs @@ -112,7 +112,7 @@ impl ParquetRecordBatchStreamBuilder { /// Only read data from the provided column indexes pub fn with_projection(self, projection: Vec) -> Self { Self { - projection: Some(projection.into()), + projection: Some(projection), ..self } } @@ -339,7 +339,7 @@ async fn read_footer( let mut buf = [0_u8; 8]; input.read_exact(&mut buf).await?; - if &buf[4..] != PARQUET_MAGIC { + if buf[4..] != PARQUET_MAGIC { return Err(general_err!("Invalid Parquet file. Corrupt footer")); }