You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "godfrey he (Jira)" <ji...@apache.org> on 2020/02/28 02:41:00 UTC
[jira] [Created] (FLINK-16322) wrong result after filter push down
in parquet table source
godfrey he created FLINK-16322:
----------------------------------
Summary: wrong result after filter push down in parquet table source
Key: FLINK-16322
URL: https://issues.apache.org/jira/browse/FLINK-16322
Project: Flink
Issue Type: Bug
Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
Reporter: godfrey he
Attachments: parquet-1-1.parquet
I get the wrong result when run the following query:
source schema:
first VARCHAR
id INT
score DOUBLE
last VARCHAR
data: (parquet file is in the attachment)
("Mike", 1, 12.3d, "Smith"),
("Bob", 2, 45.6d, "Taylor"),
("Sam", 3, 7.89d, "Miller"),
("Peter", 4, 0.12d, "Smith"),
("Liz", 5, 34.5d, "Williams"),
("Sally", 6, 6.78d, "Miller"),
("Alice", 7, 90.1d, "Smith"),
("Kelly", 8, 2.34d, "Williams")
query:
SELECT id, `first`, `last`, score FROM ParquetTable WHERE score < 3
the expected result size is 2, however the actual result size is 0.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)