Skip to content

Commit

Permalink
Log error building row filters
Browse files Browse the repository at this point in the history
  • Loading branch information
alamb committed Oct 27, 2022
1 parent e73a43c commit d7f2fba
Showing 1 changed file with 15 additions and 4 deletions.
19 changes: 15 additions & 4 deletions datafusion/core/src/physical_plan/file_format/parquet.rs
Original file line number Diff line number Diff line change
Expand Up @@ -450,15 +450,26 @@ impl FileOpener for ParquetOpener {
.then(|| pruning_predicate.as_ref().map(|p| p.logical_expr()))
.flatten()
{
if let Ok(Some(filter)) = build_row_filter(
let row_filter = build_row_filter(
predicate.clone(),
builder.schema().as_ref(),
table_schema.as_ref(),
builder.metadata(),
reorder_predicates,
) {
builder = builder.with_row_filter(filter);
}
);

match row_filter {
Ok(Some(filter)) => {
builder = builder.with_row_filter(filter);
}
Ok(None) => {}
Err(e) => {
debug!(
"Ignoring error building row filter for '{:?}': {}",
predicate, e
);
}
};
};

let file_metadata = builder.metadata();
Expand Down

0 comments on commit d7f2fba

Please sign in to comment.