Skip to content

Commit 4531afa

Browse files
committed
fix: Fix CI failing due to apache#16686
1 parent a17292d commit 4531afa

File tree

1 file changed

+10
-1
lines changed

1 file changed

+10
-1
lines changed

datafusion/datasource/src/source.rs

Lines changed: 10 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;
@@ -341,7 +342,15 @@ impl ExecutionPlan for DataSourceExec {
341342
new_node.cache =
342343
Self::compute_properties(Arc::clone(&new_node.data_source));
343344
// Recompute equivalence info using new filters
344-
let filter = conjunction(res.filters.collect_supported());
345+
let filter = conjunction(
346+
res.filters
347+
.iter()
348+
.filter_map(|f| match f {
349+
PredicateSupport::Supported(expr) => Some(Arc::clone(expr)),
350+
PredicateSupport::Unsupported(_) => None,
351+
})
352+
.collect_vec(),
353+
);
345354
new_node = new_node.add_filter_equivalence_info(filter)?;
346355
Ok(FilterPushdownPropagation {
347356
filters: res.filters,

0 commit comments

Comments
 (0)