(datafusion-comet) 05/14: Fix Q1.

[ag...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

agrove pushed a commit to branch comet-parquet-exec
in repository https://gitbox.apache.org/repos/asf/datafusion-comet.git

commit fb68558ab11b66e0ec4b9f6b248d4e3c512c3869
Author: Matt Butrovich <mb...@gmail.com>
AuthorDate: Sat Nov 9 09:55:58 2024 -0500

    Fix Q1.
---
 native/core/src/execution/datafusion/planner.rs | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/native/core/src/execution/datafusion/planner.rs b/native/core/src/execution/datafusion/planner.rs
index df163bef..d49d8dbb 100644
--- a/native/core/src/execution/datafusion/planner.rs
+++ b/native/core/src/execution/datafusion/planner.rs
@@ -961,17 +961,17 @@ impl PhysicalPlanner {
                             &data_schema_descriptor,
                             None,
                         )
-                        .unwrap(),
+                        .unwrap()
                     );
                     println!("data_schema_arrow: {:?}", data_schema_arrow);
 
                     let required_schema_descriptor =
                         parquet::schema::types::SchemaDescriptor::new(Arc::new(required_schema));
-                    let required_schema_arrow = parquet::arrow::schema::parquet_to_arrow_schema(
+                    let required_schema_arrow = Arc::new(parquet::arrow::schema::parquet_to_arrow_schema(
                         &required_schema_descriptor,
                         None,
                     )
-                    .unwrap();
+                    .unwrap());
                     println!("required_schema_arrow: {:?}", required_schema_arrow);
 
                     assert!(!required_schema_arrow.fields.is_empty());
@@ -990,7 +990,7 @@ impl PhysicalPlanner {
                     let data_filters: Result<Vec<Arc<dyn PhysicalExpr>>, ExecutionError> = scan
                         .data_filters
                         .iter()
-                        .map(|expr| self.create_expr(expr, Arc::clone(&data_schema_arrow)))
+                        .map(|expr| self.create_expr(expr, Arc::clone(&required_schema_arrow)))
                         .collect();
 
                     // Create a conjunctive form of the vector because ParquetExecBuilder takes


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@datafusion.apache.org
For additional commands, e-mail: commits-help@datafusion.apache.org