Hector Rios created FLINK-33010: ----------------------------------- Summary: NPE when using GREATEST() in Flink SQL Key: FLINK-33010 URL: https://issues.apache.org/jira/browse/FLINK-33010 Project: Flink Issue Type: Bug Components: Table SQL / API, Table SQL / Planner Affects Versions: 1.16.2, 1.16.1 Reporter: Hector Rios
Hi, I see NPEs in flink 1.14 and flink 1.16 when running queries with GREATEST() and timestamps. Below is an example to help in reproducing the issue. {code:java} CREATE TEMPORARY VIEW Positions AS SELECT SecurityId, ccy1, CAST(publishTimestamp AS TIMESTAMP(3)) as publishTimestampFROM (VALUES (1, 'USD', '2022-01-01'), (2, 'GBP', '2022-02-02'), (3, 'GBX', '2022-03-03'), (4, 'GBX', '2022-04-4')) AS ccy(SecurityId, ccy1, publishTimestamp); CREATE TEMPORARY VIEW Benchmarks AS SELECT SecurityId, ccy1, CAST(publishTimestamp AS TIMESTAMP(3)) as publishTimestampFROM (VALUES (3, 'USD', '2023-01-01'), (4, 'GBP', '2023-02-02'), (5, 'GBX', '2023-03-03'), (6, 'GBX', '2023-04-4')) AS ccy(SecurityId, ccy1, publishTimestamp); SELECT *, GREATEST( IFNULL(Positions.publishTimestamp,CAST('1970-1-1' AS TIMESTAMP(3))), IFNULL(Benchmarks.publishTimestamp,CAST('1970-1-1' AS TIMESTAMP(3))) ) FROM Positions FULL JOIN Benchmarks ON Positions.SecurityId = Benchmarks.SecurityId {code} Using "IF" is a workaround at the moment instead of using "GREATEST" -- This message was sent by Atlassian Jira (v8.20.10#820010)