From a0cb27c305cbfc4b12e0862c228adac62fe62cf5 Mon Sep 17 00:00:00 2001 From: Andrew Lamb Date: Thu, 13 Oct 2022 14:50:52 -0400 Subject: [PATCH] Fixup test --- .../core/src/physical_plan/file_format/parquet.rs | 12 ++++-------- 1 file changed, 4 insertions(+), 8 deletions(-) diff --git a/datafusion/core/src/physical_plan/file_format/parquet.rs b/datafusion/core/src/physical_plan/file_format/parquet.rs index d5f5a09069d49..b6998df63f51b 100644 --- a/datafusion/core/src/physical_plan/file_format/parquet.rs +++ b/datafusion/core/src/physical_plan/file_format/parquet.rs @@ -959,7 +959,7 @@ mod tests { let file_groups = meta.into_iter().map(Into::into).collect(); // prepare the scan - let mut parquet_exec = ParquetExec::new( + let parquet_exec = ParquetExec::new( FileScanConfig { object_store_url: ObjectStoreUrl::local_filesystem(), file_groups: vec![file_groups], @@ -972,13 +972,9 @@ mod tests { }, predicate, None, - ); - - if pushdown_predicate { - parquet_exec = parquet_exec - .with_pushdown_filters(true) - .with_reorder_filters(true); - } + ) + .with_pushdown_filters(pushdown_predicate) + .with_reorder_filters(pushdown_predicate); let session_ctx = SessionContext::new(); let task_ctx = session_ctx.task_ctx();