[jira] [Updated] (FLINK-14200) Temporal Table Function Joins do not work on Tables (only TableSources) on the query side
[ https://issues.apache.org/jira/browse/FLINK-14200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14200: - Fix Version/s: 1.10.0 > Temporal Table Function Joins do not work on Tables (only TableSources) on > the query side > - > > Key: FLINK-14200 > URL: https://issues.apache.org/jira/browse/FLINK-14200 > Project: Flink > Issue Type: Bug > Components: Table SQL / Planner >Affects Versions: 1.9.0 > Environment: Java 8, Scala 2.11, Flink 1.9 >Reporter: Benoît Paris >Assignee: Jark Wu >Priority: Major > Labels: pull-request-available > Fix For: 1.9.2, 1.10.0 > > Attachments: > temporal-table-function-query-side-as-not-table-source.zip > > Time Spent: 10m > Remaining Estimate: 0h > > This only affects the Blink planner. The legacy planner works fine. > With Orders as a TableSource, and Orders2 as a Table with the same content: > {code:java} > tEnv.registerTableSource("Orders", new FooSource(new String[] {"o_currency", > "o_amount", "o_proctime"})); > Table orders2 = tEnv.sqlQuery("SELECT * FROM Orders"); > tEnv.registerTable("Orders2", orders2);{code} > This works (TableSource on the query side): > {code:java} > SELECT > o_amount * r_amount AS amount > FROM Orders > , LATERAL TABLE (Rates(o_proctime)) > WHERE r_currency = o_currency{code} > While this does not (Table on the query side): > {code:java} > SELECT > o_amount * r_amount AS amount > FROM Orders2 > , LATERAL TABLE (Rates(o_proctime)) > WHERE r_currency = o_currency{code} > Throwing an NPE in FlinkRelBuilder, called from > LogicalCorrelateToJoinFromTemporalTableFunctionRule. Attached is Java code > for reproduction, along with the full log and stacktrace, and a pom.xml. > EDIT: This may not be Table vs TableSource, maybe more a projection or a > decorrelate issue? Don't know how the planner works well enough to > characterize it better. > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-14200) Temporal Table Function Joins do not work on Tables (only TableSources) on the query side
[ https://issues.apache.org/jira/browse/FLINK-14200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14200: --- Labels: pull-request-available (was: ) > Temporal Table Function Joins do not work on Tables (only TableSources) on > the query side > - > > Key: FLINK-14200 > URL: https://issues.apache.org/jira/browse/FLINK-14200 > Project: Flink > Issue Type: Bug > Components: Table SQL / Planner >Affects Versions: 1.9.0 > Environment: Java 8, Scala 2.11, Flink 1.9 >Reporter: Benoît Paris >Assignee: Jark Wu >Priority: Major > Labels: pull-request-available > Fix For: 1.9.2 > > Attachments: > temporal-table-function-query-side-as-not-table-source.zip > > > This only affects the Blink planner. The legacy planner works fine. > With Orders as a TableSource, and Orders2 as a Table with the same content: > {code:java} > tEnv.registerTableSource("Orders", new FooSource(new String[] {"o_currency", > "o_amount", "o_proctime"})); > Table orders2 = tEnv.sqlQuery("SELECT * FROM Orders"); > tEnv.registerTable("Orders2", orders2);{code} > This works (TableSource on the query side): > {code:java} > SELECT > o_amount * r_amount AS amount > FROM Orders > , LATERAL TABLE (Rates(o_proctime)) > WHERE r_currency = o_currency{code} > While this does not (Table on the query side): > {code:java} > SELECT > o_amount * r_amount AS amount > FROM Orders2 > , LATERAL TABLE (Rates(o_proctime)) > WHERE r_currency = o_currency{code} > Throwing an NPE in FlinkRelBuilder, called from > LogicalCorrelateToJoinFromTemporalTableFunctionRule. Attached is Java code > for reproduction, along with the full log and stacktrace, and a pom.xml. > EDIT: This may not be Table vs TableSource, maybe more a projection or a > decorrelate issue? Don't know how the planner works well enough to > characterize it better. > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-14200) Temporal Table Function Joins do not work on Tables (only TableSources) on the query side
[ https://issues.apache.org/jira/browse/FLINK-14200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14200: Fix Version/s: (was: 1.9.1) 1.9.2 > Temporal Table Function Joins do not work on Tables (only TableSources) on > the query side > - > > Key: FLINK-14200 > URL: https://issues.apache.org/jira/browse/FLINK-14200 > Project: Flink > Issue Type: Bug > Components: Table SQL / Planner >Affects Versions: 1.9.0 > Environment: Java 8, Scala 2.11, Flink 1.9 >Reporter: Benoît Paris >Priority: Major > Fix For: 1.9.2 > > Attachments: > temporal-table-function-query-side-as-not-table-source.zip > > > This only affects the Blink planner. The legacy planner works fine. > With Orders as a TableSource, and Orders2 as a Table with the same content: > {code:java} > tEnv.registerTableSource("Orders", new FooSource(new String[] {"o_currency", > "o_amount", "o_proctime"})); > Table orders2 = tEnv.sqlQuery("SELECT * FROM Orders"); > tEnv.registerTable("Orders2", orders2);{code} > This works (TableSource on the query side): > {code:java} > SELECT > o_amount * r_amount AS amount > FROM Orders > , LATERAL TABLE (Rates(o_proctime)) > WHERE r_currency = o_currency{code} > While this does not (Table on the query side): > {code:java} > SELECT > o_amount * r_amount AS amount > FROM Orders2 > , LATERAL TABLE (Rates(o_proctime)) > WHERE r_currency = o_currency{code} > Throwing an NPE in FlinkRelBuilder, called from > LogicalCorrelateToJoinFromTemporalTableFunctionRule. Attached is Java code > for reproduction, along with the full log and stacktrace, and a pom.xml. > EDIT: This may not be Table vs TableSource, maybe more a projection or a > decorrelate issue? Don't know how the planner works well enough to > characterize it better. > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-14200) Temporal Table Function Joins do not work on Tables (only TableSources) on the query side
[ https://issues.apache.org/jira/browse/FLINK-14200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14200: Fix Version/s: 1.9.1 > Temporal Table Function Joins do not work on Tables (only TableSources) on > the query side > - > > Key: FLINK-14200 > URL: https://issues.apache.org/jira/browse/FLINK-14200 > Project: Flink > Issue Type: Bug > Components: Table SQL / Planner >Affects Versions: 1.9.0 > Environment: Java 8, Scala 2.11, Flink 1.9 >Reporter: Benoît Paris >Priority: Major > Fix For: 1.9.1 > > Attachments: > temporal-table-function-query-side-as-not-table-source.zip > > > This only affects the Blink planner. The legacy planner works fine. > With Orders as a TableSource, and Orders2 as a Table with the same content: > {code:java} > tEnv.registerTableSource("Orders", new FooSource(new String[] {"o_currency", > "o_amount", "o_proctime"})); > Table orders2 = tEnv.sqlQuery("SELECT * FROM Orders"); > tEnv.registerTable("Orders2", orders2);{code} > This works (TableSource on the query side): > {code:java} > SELECT > o_amount * r_amount AS amount > FROM Orders > , LATERAL TABLE (Rates(o_proctime)) > WHERE r_currency = o_currency{code} > While this does not (Table on the query side): > {code:java} > SELECT > o_amount * r_amount AS amount > FROM Orders2 > , LATERAL TABLE (Rates(o_proctime)) > WHERE r_currency = o_currency{code} > Throwing an NPE in FlinkRelBuilder, called from > LogicalCorrelateToJoinFromTemporalTableFunctionRule. Attached is Java code > for reproduction, along with the full log and stacktrace, and a pom.xml. > EDIT: This may not be Table vs TableSource, maybe more a projection or a > decorrelate issue? Don't know how the planner works well enough to > characterize it better. > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-14200) Temporal Table Function Joins do not work on Tables (only TableSources) on the query side
[ https://issues.apache.org/jira/browse/FLINK-14200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benoît Paris updated FLINK-14200: - Description: This only affects the Blink planner. The legacy planner works fine. With Orders as a TableSource, and Orders2 as a Table with the same content: {code:java} tEnv.registerTableSource("Orders", new FooSource(new String[] {"o_currency", "o_amount", "o_proctime"})); Table orders2 = tEnv.sqlQuery("SELECT * FROM Orders"); tEnv.registerTable("Orders2", orders2);{code} This works (TableSource on the query side): {code:java} SELECT o_amount * r_amount AS amount FROM Orders , LATERAL TABLE (Rates(o_proctime)) WHERE r_currency = o_currency{code} While this does not (Table on the query side): {code:java} SELECT o_amount * r_amount AS amount FROM Orders2 , LATERAL TABLE (Rates(o_proctime)) WHERE r_currency = o_currency{code} Throwing an NPE in FlinkRelBuilder, called from LogicalCorrelateToJoinFromTemporalTableFunctionRule. Attached is Java code for reproduction, along with the full log and stacktrace, and a pom.xml. EDIT: This may not be Table vs TableSource, maybe more a projection or a decorrelate issue? Don't know how the planner works well enough to characterize it better. was: This only affects the Blink planner. The legacy planner works fine. With Orders as a TableSource, and Orders2 as a Table with the same content: {code:java} tEnv.registerTableSource("Orders", new FooSource(new String[] {"o_currency", "o_amount", "o_proctime"})); Table orders2 = tEnv.sqlQuery("SELECT * FROM Orders"); tEnv.registerTable("Orders2", orders2);{code} This works (TableSource on the query side): {code:java} SELECT o_amount * r_amount AS amount FROM Orders , LATERAL TABLE (Rates(o_proctime)) WHERE r_currency = o_currency{code} While this does not (Table on the query side): {code:java} SELECT o_amount * r_amount AS amount FROM Orders2 , LATERAL TABLE (Rates(o_proctime)) WHERE r_currency = o_currency{code} Throwing an NPE in FlinkRelBuilder, called from LogicalCorrelateToJoinFromTemporalTableFunctionRule. Attached is Java code for reproduction, along with the full log and stacktrace, and a pom.xml. EDIT: This maybe not be Table vs TableSource, maybe more a projection or a decorrelate issue? Don't know how the planner works well enough to characterize it better. > Temporal Table Function Joins do not work on Tables (only TableSources) on > the query side > - > > Key: FLINK-14200 > URL: https://issues.apache.org/jira/browse/FLINK-14200 > Project: Flink > Issue Type: Bug > Components: Table SQL / Planner >Affects Versions: 1.9.0 > Environment: Java 8, Scala 2.11, Flink 1.9 >Reporter: Benoît Paris >Priority: Major > Attachments: > temporal-table-function-query-side-as-not-table-source.zip > > > This only affects the Blink planner. The legacy planner works fine. > With Orders as a TableSource, and Orders2 as a Table with the same content: > {code:java} > tEnv.registerTableSource("Orders", new FooSource(new String[] {"o_currency", > "o_amount", "o_proctime"})); > Table orders2 = tEnv.sqlQuery("SELECT * FROM Orders"); > tEnv.registerTable("Orders2", orders2);{code} > This works (TableSource on the query side): > {code:java} > SELECT > o_amount * r_amount AS amount > FROM Orders > , LATERAL TABLE (Rates(o_proctime)) > WHERE r_currency = o_currency{code} > While this does not (Table on the query side): > {code:java} > SELECT > o_amount * r_amount AS amount > FROM Orders2 > , LATERAL TABLE (Rates(o_proctime)) > WHERE r_currency = o_currency{code} > Throwing an NPE in FlinkRelBuilder, called from > LogicalCorrelateToJoinFromTemporalTableFunctionRule. Attached is Java code > for reproduction, along with the full log and stacktrace, and a pom.xml. > EDIT: This may not be Table vs TableSource, maybe more a projection or a > decorrelate issue? Don't know how the planner works well enough to > characterize it better. > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-14200) Temporal Table Function Joins do not work on Tables (only TableSources) on the query side
[ https://issues.apache.org/jira/browse/FLINK-14200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benoît Paris updated FLINK-14200: - Description: This only affects the Blink planner. The legacy planner works fine. With Orders as a TableSource, and Orders2 as a Table with the same content: {code:java} tEnv.registerTableSource("Orders", new FooSource(new String[] {"o_currency", "o_amount", "o_proctime"})); Table orders2 = tEnv.sqlQuery("SELECT * FROM Orders"); tEnv.registerTable("Orders2", orders2);{code} This works (TableSource on the query side): {code:java} SELECT o_amount * r_amount AS amount FROM Orders , LATERAL TABLE (Rates(o_proctime)) WHERE r_currency = o_currency{code} While this does not (Table on the query side): {code:java} SELECT o_amount * r_amount AS amount FROM Orders2 , LATERAL TABLE (Rates(o_proctime)) WHERE r_currency = o_currency{code} Throwing an NPE in FlinkRelBuilder, called from LogicalCorrelateToJoinFromTemporalTableFunctionRule. Attached is Java code for reproduction, along with the full log and stacktrace, and a pom.xml. EDIT: This maybe not be Table vs TableSource, maybe more a projection or a decorrelate issue? Don't know how the planner works well enough to characterize it better. was: This only affects the Blink planner. The legacy planner works fine. With Orders as a TableSource, and Orders2 as a Table with the same content: {code:java} tEnv.registerTableSource("Orders", new FooSource(new String[] {"o_currency", "o_amount", "o_proctime"})); Table orders2 = tEnv.sqlQuery("SELECT * FROM Orders"); tEnv.registerTable("Orders2", orders2);{code} This works (TableSource on the query side): {code:java} SELECT o_amount * r_amount AS amount FROM Orders , LATERAL TABLE (Rates(o_proctime)) WHERE r_currency = o_currency{code} While this does not (Table on the query side): {code:java} SELECT o_amount * r_amount AS amount FROM Orders2 , LATERAL TABLE (Rates(o_proctime)) WHERE r_currency = o_currency{code} Throwing an NPE in FlinkRelBuilder, called from LogicalCorrelateToJoinFromTemporalTableFunctionRule. Attached is Java code for reproduction, along with the full log and stacktrace, and a pom.xml. > Temporal Table Function Joins do not work on Tables (only TableSources) on > the query side > - > > Key: FLINK-14200 > URL: https://issues.apache.org/jira/browse/FLINK-14200 > Project: Flink > Issue Type: Bug > Components: Table SQL / Planner >Affects Versions: 1.9.0 > Environment: Java 8, Scala 2.11, Flink 1.9 >Reporter: Benoît Paris >Priority: Major > Attachments: > temporal-table-function-query-side-as-not-table-source.zip > > > This only affects the Blink planner. The legacy planner works fine. > With Orders as a TableSource, and Orders2 as a Table with the same content: > {code:java} > tEnv.registerTableSource("Orders", new FooSource(new String[] {"o_currency", > "o_amount", "o_proctime"})); > Table orders2 = tEnv.sqlQuery("SELECT * FROM Orders"); > tEnv.registerTable("Orders2", orders2);{code} > This works (TableSource on the query side): > {code:java} > SELECT > o_amount * r_amount AS amount > FROM Orders > , LATERAL TABLE (Rates(o_proctime)) > WHERE r_currency = o_currency{code} > While this does not (Table on the query side): > {code:java} > SELECT > o_amount * r_amount AS amount > FROM Orders2 > , LATERAL TABLE (Rates(o_proctime)) > WHERE r_currency = o_currency{code} > Throwing an NPE in FlinkRelBuilder, called from > LogicalCorrelateToJoinFromTemporalTableFunctionRule. Attached is Java code > for reproduction, along with the full log and stacktrace, and a pom.xml. > EDIT: This maybe not be Table vs TableSource, maybe more a projection or a > decorrelate issue? Don't know how the planner works well enough to > characterize it better. > -- This message was sent by Atlassian Jira (v8.3.4#803005)