diff --git a/src/daft-parquet/src/stream_reader.rs b/src/daft-parquet/src/stream_reader.rs index fd77efe886..58a3662cf0 100644 --- a/src/daft-parquet/src/stream_reader.rs +++ b/src/daft-parquet/src/stream_reader.rs @@ -111,8 +111,12 @@ pub fn arrow_column_iters_to_table_iter( } index_so_far += len; - let mut table = Table::new_with_size(owned_schema_ref.clone(), all_series, len) - .with_context(|_| super::UnableToCreateTableFromChunkSnafu { path: uri.clone() })?; + let mut table = Table::new_with_size( + Schema::new(all_series.iter().map(|s| s.field().clone()).collect())?, + all_series, + len, + ) + .with_context(|_| super::UnableToCreateTableFromChunkSnafu { path: uri.clone() })?; // Apply pushdowns if needed if let Some(predicate) = &predicate { table = table.filter(&[predicate.clone()])?;