Skip to content

Commit d7f2fba

Browse files
committed
1 parent e73a43c commit d7f2fba

File tree

1 file changed

+15
-4
lines changed
  • datafusion/core/src/physical_plan/file_format

1 file changed

+15
-4
lines changed

datafusion/core/src/physical_plan/file_format/parquet.rs

Lines changed: 15 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -450,15 +450,26 @@ impl FileOpener for ParquetOpener {
450450
.then(|| pruning_predicate.as_ref().map(|p| p.logical_expr()))
451451
.flatten()
452452
{
453-
if let Ok(Some(filter)) = build_row_filter(
453+
let row_filter = build_row_filter(
454454
predicate.clone(),
455455
builder.schema().as_ref(),
456456
table_schema.as_ref(),
457457
builder.metadata(),
458458
reorder_predicates,
459-
) {
460-
builder = builder.with_row_filter(filter);
461-
}
459+
);
460+
461+
match row_filter {
462+
Ok(Some(filter)) => {
463+
builder = builder.with_row_filter(filter);
464+
}
465+
Ok(None) => {}
466+
Err(e) => {
467+
debug!(
468+
"Ignoring error building row filter for '{:?}': {}",
469+
predicate, e
470+
);
471+
}
472+
};
462473
};
463474

464475
let file_metadata = builder.metadata();

0 commit comments

Comments
 (0)