diff --git a/datafusion/core/src/datasource/physical_plan/parquet/opener.rs b/datafusion/core/src/datasource/physical_plan/parquet/opener.rs index ffe879eb8de0..b6dfa4569ee9 100644 --- a/datafusion/core/src/datasource/physical_plan/parquet/opener.rs +++ b/datafusion/core/src/datasource/physical_plan/parquet/opener.rs @@ -92,7 +92,9 @@ impl FileOpener for ParquetOpener { let limit = self.limit; Ok(Box::pin(async move { - let options = ArrowReaderOptions::new().with_page_index(enable_page_index); + let options = ArrowReaderOptions::new() + .with_page_index(enable_page_index) + .with_schema(table_schema.clone()); let mut builder = ParquetRecordBatchStreamBuilder::new_with_options(reader, options) .await?;