From ab9a79e296d4419e5a96bfa72e2dfd5006578007 Mon Sep 17 00:00:00 2001 From: Jay Chia Date: Thu, 10 Oct 2024 15:38:19 -0700 Subject: [PATCH] [BUG] Fix reading of logical types from Parquet files in s3 --- src/daft-parquet/src/file.rs | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/src/daft-parquet/src/file.rs b/src/daft-parquet/src/file.rs index 02b57ed6f9..8c582dd24e 100644 --- a/src/daft-parquet/src/file.rs +++ b/src/daft-parquet/src/file.rs @@ -733,10 +733,9 @@ impl ParquetFileReader { })? .into_iter() .collect::>>()?; - let daft_schema = daft_core::prelude::Schema::try_from(self.arrow_schema.as_ref())?; Table::new_with_size( - daft_schema, + Schema::new(all_series.iter().map(|s| s.field().clone()).collect())?, all_series, self.row_ranges.as_ref().iter().map(|rr| rr.num_rows).sum(), )