[FLINK-21520] ParquetInputFormat#setfilterPredicate() does not work

• Type: Bug
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
• Labels: auto-deprioritized-major auto-deprioritized-minor
• Assignee: Unassigned
• Reporter: Etienne Chauchot
• Created: 26/Feb/21 14:20
• Updated: 04/Dec/21 10:39

Description

Simplified code:

 FilterPredicate filterPredicate = eq(intColumn("intField"), 10);
parquetInputFormat.setFilterPredicate(filterPredicate);
env.createInput(parquetInputFormat);

produces no records whereas

env.createInput(parquetInputFormat)
.filter((FilterFunction) value ->  value.get("intField") == 10);

produces records.