Skip to content

Commit 5648201

Browse files
authored
fix: Fix CI failing due to #16686 (#16718)
* fix: Fix CI failing due to #16686 * fix * add original comment * change
1 parent a17292d commit 5648201

1 file changed

Lines changed: 11 additions & 1 deletion

File tree

datafusion/datasource/src/source.rs

Lines changed: 11 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,7 @@ use datafusion_physical_plan::projection::ProjectionExec;
3030
use datafusion_physical_plan::{
3131
DisplayAs, DisplayFormatType, ExecutionPlan, PlanProperties,
3232
};
33+
use itertools::Itertools;
3334

3435
use crate::file_scan_config::FileScanConfig;
3536
use datafusion_common::config::ConfigOptions;
@@ -340,8 +341,17 @@ impl ExecutionPlan for DataSourceExec {
340341
new_node.data_source = data_source;
341342
new_node.cache =
342343
Self::compute_properties(Arc::clone(&new_node.data_source));
344+
343345
// Recompute equivalence info using new filters
344-
let filter = conjunction(res.filters.collect_supported());
346+
let filter = conjunction(
347+
res.filters
348+
.iter()
349+
.filter_map(|f| match f {
350+
PredicateSupport::Supported(expr) => Some(Arc::clone(expr)),
351+
PredicateSupport::Unsupported(_) => None,
352+
})
353+
.collect_vec(),
354+
);
345355
new_node = new_node.add_filter_equivalence_info(filter)?;
346356
Ok(FilterPushdownPropagation {
347357
filters: res.filters,

0 commit comments

Comments
 (0)