[jira] [Updated] (FLINK-33010) NPE when using GREATEST() in Flink SQL
[ https://issues.apache.org/jira/browse/FLINK-33010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-33010: Fix Version/s: 1.18.0 > 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.1, 1.16.2 >Reporter: Hector Rios >Assignee: Sergey Nuyanzin >Priority: Minor > Labels: pull-request-available > Fix For: 1.18.0, 1.16.3, 1.17.2, 1.19.0 > > > 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 publishTimestamp > FROM (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 publishTimestamp > FROM (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)
[jira] [Updated] (FLINK-33010) NPE when using GREATEST() in Flink SQL
[ https://issues.apache.org/jira/browse/FLINK-33010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-33010: Fix Version/s: 1.17.2 > 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.1, 1.16.2 >Reporter: Hector Rios >Assignee: Sergey Nuyanzin >Priority: Minor > Labels: pull-request-available > Fix For: 1.16.3, 1.17.2, 1.19.0 > > > 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 publishTimestamp > FROM (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 publishTimestamp > FROM (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)
[jira] [Updated] (FLINK-33010) NPE when using GREATEST() in Flink SQL
[ https://issues.apache.org/jira/browse/FLINK-33010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-33010: Fix Version/s: 1.16.3 > 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.1, 1.16.2 >Reporter: Hector Rios >Assignee: Sergey Nuyanzin >Priority: Minor > Labels: pull-request-available > Fix For: 1.16.3, 1.19.0 > > > 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 publishTimestamp > FROM (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 publishTimestamp > FROM (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)
[jira] [Updated] (FLINK-33010) NPE when using GREATEST() in Flink SQL
[ https://issues.apache.org/jira/browse/FLINK-33010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-33010: Labels: pull-request-available (was: ) > 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.1, 1.16.2 >Reporter: Hector Rios >Assignee: Sergey Nuyanzin >Priority: Minor > Labels: pull-request-available > > 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 publishTimestamp > FROM (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 publishTimestamp > FROM (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)
[jira] [Updated] (FLINK-33010) NPE when using GREATEST() in Flink SQL
[ https://issues.apache.org/jira/browse/FLINK-33010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hector Rios updated FLINK-33010: Description: 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 publishTimestamp FROM (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 publishTimestamp FROM (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" was: 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" > 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.1, 1.16.2 >Reporter: Hector Rios >Priority: Minor > > 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 publishTimestamp > FROM (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 publishTimestamp > FROM (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)