[jira] [Commented] (FLINK-24352) Lookup join + WITH clause throws NPE

2021-12-31 Thread Yuval Itzchakov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17467154#comment-17467154 ] Yuval Itzchakov commented on FLINK-24352: - [~godfreyhe] Thanks for merging! I'd

[jira] [Commented] (FLINK-24352) Lookup join + WITH clause throws NPE

2021-11-21 Thread Yuval Itzchakov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447028#comment-17447028 ] Yuval Itzchakov commented on FLINK-24352: - [~TsReaper] It's ready: [https://gith

[jira] [Commented] (FLINK-24956) SqlSnapshot throws NullPointerException when used in conjunction with CTE

2021-11-20 Thread Yuval Itzchakov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17446935#comment-17446935 ] Yuval Itzchakov commented on FLINK-24956: - [~TsReaper] https://github.com/apache

[jira] [Commented] (FLINK-24956) SqlSnapshot throws NullPointerException when used in conjunction with CTE

2021-11-18 Thread Yuval Itzchakov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17446077#comment-17446077 ] Yuval Itzchakov commented on FLINK-24956: - I just saw the code from Calcites val

[jira] (FLINK-24956) SqlSnapshot throws NullPointerException when used in conjunction with CTE

2021-11-18 Thread Yuval Itzchakov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24956 ] Yuval Itzchakov deleted comment on FLINK-24956: - was (Author: yuval.itzchakov): One way I see to work around the Calcite bug is to override the method in FlinkCalciteSqlValidator with th

[jira] [Commented] (FLINK-24956) SqlSnapshot throws NullPointerException when used in conjunction with CTE

2021-11-18 Thread Yuval Itzchakov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17446062#comment-17446062 ] Yuval Itzchakov commented on FLINK-24956: - One way I see to work around the Calc

[jira] [Created] (FLINK-24956) SqlSnapshot throws NullPointerException when used in conjunction with CTE

2021-11-18 Thread Yuval Itzchakov (Jira)
Yuval Itzchakov created FLINK-24956: --- Summary: SqlSnapshot throws NullPointerException when used in conjunction with CTE Key: FLINK-24956 URL: https://issues.apache.org/jira/browse/FLINK-24956 Proje

[jira] [Commented] (FLINK-23919) PullUpWindowTableFunctionIntoWindowAggregateRule generates invalid Calc for Window TVF

2021-10-28 Thread Yuval Itzchakov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17435402#comment-17435402 ] Yuval Itzchakov commented on FLINK-23919: - Anyone? > PullUpWindowTableFunctionI

[jira] [Commented] (FLINK-23919) PullUpWindowTableFunctionIntoWindowAggregateRule generates invalid Calc for Window TVF

2021-10-10 Thread Yuval Itzchakov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17426829#comment-17426829 ] Yuval Itzchakov commented on FLINK-23919: - [~jark] [~jinyu.zj] Did one of you gu

[jira] [Updated] (FLINK-23919) PullUpWindowTableFunctionIntoWindowAggregateRule generates invalid Calc for Window TVF

2021-08-23 Thread Yuval Itzchakov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuval Itzchakov updated FLINK-23919: Description: Given the following Window TVF: {code:java} SELECT window_time, MIN(a

[jira] [Updated] (FLINK-23919) PullUpWindowTableFunctionIntoWindowAggregateRule generates invalid Calc for Window TVF

2021-08-23 Thread Yuval Itzchakov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuval Itzchakov updated FLINK-23919: Description: Given the following Window TVF: {code:java} SELECT window_time, MIN(a

[jira] [Updated] (FLINK-23919) PullUpWindowTableFunctionIntoWindowAggregateRule generates invalid Calc for Window TVF

2021-08-23 Thread Yuval Itzchakov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuval Itzchakov updated FLINK-23919: Attachment: image-2021-08-23-13-31-24-052.png > PullUpWindowTableFunctionIntoWindowAggrega

[jira] [Updated] (FLINK-23919) PullUpWindowTableFunctionIntoWindowAggregateRule generates invalid Calc for Window TVF

2021-08-23 Thread Yuval Itzchakov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuval Itzchakov updated FLINK-23919: Description: Given the following Window TVF: {code:java} SELECT window_time, MIN(a

[jira] [Created] (FLINK-23919) PullUpWindowTableFunctionIntoWindowAggregateRule generates invalid Calc for Window TVF

2021-08-23 Thread Yuval Itzchakov (Jira)
Yuval Itzchakov created FLINK-23919: --- Summary: PullUpWindowTableFunctionIntoWindowAggregateRule generates invalid Calc for Window TVF Key: FLINK-23919 URL: https://issues.apache.org/jira/browse/FLINK-23919

[jira] [Commented] (FLINK-21675) Push filter into the scan when watermark assigner is the parent of the table scan

2021-03-24 Thread Yuval Itzchakov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308396#comment-17308396 ] Yuval Itzchakov commented on FLINK-21675: - @Shengkai Fang Hey, would appreciate

[jira] [Commented] (FLINK-21675) Push filter into the scan when watermark assigner is the parent of the table scan

2021-03-21 Thread Yuval Itzchakov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17305689#comment-17305689 ] Yuval Itzchakov commented on FLINK-21675: - PR: https://github.com/apache/flink/p

[jira] [Comment Edited] (FLINK-21675) Push filter into the scan when watermark assigner is the parent of the table scan

2021-03-17 Thread Yuval Itzchakov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17303659#comment-17303659 ] Yuval Itzchakov edited comment on FLINK-21675 at 3/17/21, 6:57 PM: ---

[jira] [Commented] (FLINK-21675) Push filter into the scan when watermark assigner is the parent of the table scan

2021-03-17 Thread Yuval Itzchakov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17303659#comment-17303659 ] Yuval Itzchakov commented on FLINK-21675: - I've implemented an initial solution

[jira] [Commented] (FLINK-20961) Flink throws NullPointerException for tables created from DataStream with no assigned timestamps and watermarks

2021-01-13 Thread Yuval Itzchakov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17264119#comment-17264119 ] Yuval Itzchakov commented on FLINK-20961: - Working on it :) > Flink throws Null

[jira] [Created] (FLINK-20961) Flink throws NullPointerException for tables created from DataStream with no assigned timestamps and watermarks

2021-01-13 Thread Yuval Itzchakov (Jira)
Yuval Itzchakov created FLINK-20961: --- Summary: Flink throws NullPointerException for tables created from DataStream with no assigned timestamps and watermarks Key: FLINK-20961 URL: https://issues.apache.org/jira

[jira] [Updated] (FLINK-20961) Flink throws NullPointerException for tables created from DataStream with no assigned timestamps and watermarks

2021-01-13 Thread Yuval Itzchakov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuval Itzchakov updated FLINK-20961: Description:   Given the following program: {code:java} //import org.apache.flink.api.com

[jira] [Updated] (FLINK-20961) Flink throws NullPointerException for tables created from DataStream with no assigned timestamps and watermarks

2021-01-13 Thread Yuval Itzchakov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuval Itzchakov updated FLINK-20961: Description:   Given the following program: {code:java} //import org.apache.flink.api.com

[jira] [Commented] (FLINK-17600) Blink Planner fails to generate RowtimeAttribute based on TableSource's DefinedRowtimeAttributes implementation

2020-05-11 Thread Yuval Itzchakov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105135#comment-17105135 ] Yuval Itzchakov commented on FLINK-17600: - [~jark] Is someone actively working o

[jira] [Commented] (FLINK-17600) Blink Planner fails to generate RowtimeAttribute based on TableSource's DefinedRowtimeAttributes implementation

2020-05-10 Thread Yuval Itzchakov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17103836#comment-17103836 ] Yuval Itzchakov commented on FLINK-17600: - Related?  [https://github.com/apache/

[jira] [Updated] (FLINK-17600) Blink Planner fails to generate RowtimeAttribute based on TableSource's DefinedRowtimeAttributes implementation

2020-05-10 Thread Yuval Itzchakov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuval Itzchakov updated FLINK-17600: Description: Given the following SQL statement:  {code:java} tableEnv.sqlQuery("SELECT EVE

[jira] [Updated] (FLINK-17600) Blink Planner fails to generate RowtimeAttribute based on TableSource's DefinedRowtimeAttributes implementation

2020-05-10 Thread Yuval Itzchakov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuval Itzchakov updated FLINK-17600: Description: Given the following SQL statement:  {code:java} tableEnv.sqlQuery("SELECT EVE

[jira] [Created] (FLINK-17600) Blink Planner fails to generate RowtimeAttribute based on TableSource's DefinedRowtimeAttributes implementation

2020-05-10 Thread Yuval Itzchakov (Jira)
Yuval Itzchakov created FLINK-17600: --- Summary: Blink Planner fails to generate RowtimeAttribute based on TableSource's DefinedRowtimeAttributes implementation Key: FLINK-17600 URL: https://issues.apache.org/jira

[jira] [Updated] (FLINK-14042) Different RelDataTypes generated for same TemporalTableFunction

2019-11-19 Thread Yuval Itzchakov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuval Itzchakov updated FLINK-14042: Affects Version/s: 1.8.2 1.9.0 1.9.1 > Diffe

[jira] [Commented] (FLINK-14042) Different RelDataTypes generated for same TemporalTableFunction

2019-10-25 Thread Yuval Itzchakov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16960124#comment-16960124 ] Yuval Itzchakov commented on FLINK-14042: - >From my tests, the problem exists in

[jira] [Created] (FLINK-14533) PushFilterIntoTableSourceScanRule misses predicate pushdowns

2019-10-25 Thread Yuval Itzchakov (Jira)
Yuval Itzchakov created FLINK-14533: --- Summary: PushFilterIntoTableSourceScanRule misses predicate pushdowns Key: FLINK-14533 URL: https://issues.apache.org/jira/browse/FLINK-14533 Project: Flink

[jira] [Updated] (FLINK-14042) Different RelDataTypes generated for same TemporalTableFunction

2019-09-10 Thread Yuval Itzchakov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuval Itzchakov updated FLINK-14042: Description: Given the following table called "foo": {code:java} SELECT event_time, b, c F

[jira] [Created] (FLINK-14042) Different RelDataTypes generated for same TemporalTableFunction

2019-09-10 Thread Yuval Itzchakov (Jira)
Yuval Itzchakov created FLINK-14042: --- Summary: Different RelDataTypes generated for same TemporalTableFunction Key: FLINK-14042 URL: https://issues.apache.org/jira/browse/FLINK-14042 Project: Flink