[FLINK-21468] ParquetTableSource: where clause on integer 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: 23/Feb/21 13:45
• Updated: 04/Dec/21 10:39

Description

Using ParquetTableSource with a parquet field mapped (at least for parquet type optional int32) to BasicTypeInfo.INT_TYPE_INFO, a SQL where clause such as

where field = 42

does not work: the data for which field == 42 is not part of the output.

I tried with a CsvTableSource with the same data and the same SQL query is executed properly.