diff --git a/datafusion/core/src/physical_plan/file_format/parquet.rs b/datafusion/core/src/physical_plan/file_format/parquet.rs index d5f5a09069d4..b6998df63f51 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();