Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-21468

ParquetTableSource: where clause on integer does not work

    XMLWordPrintableJSON

    Details

      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.

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              echauchot Etienne Chauchot
            • Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

              • Created:
                Updated: