You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/06/26 10:36:00 UTC
[jira] [Created] (FLINK-7005) Optimization steps are missing for
nested registered tables
Timo Walther created FLINK-7005:
-----------------------------------
Summary: Optimization steps are missing for nested registered tables
Key: FLINK-7005
URL: https://issues.apache.org/jira/browse/FLINK-7005
Project: Flink
Issue Type: Bug
Components: Table API & SQL
Reporter: Timo Walther
Assignee: Timo Walther
Tables that are registered (implicitly or explicitly) do not pass the first three optimization steps:
- decorrelate
- convert time indicators
- normalize the logical plan
E.g. this has the wrong plan right now:
{code}
val table = stream.toTable(tEnv, 'rowtime.rowtime, 'int, 'double, 'float, 'bigdec, 'string)
val table1 = tEnv.sql(s"""SELECT 1 + 1 FROM $table""") // not optimized
val table2 = tEnv.sql(s"""SELECT myrt FROM $table1""")
val results = table2.toAppendStream[Row]
{code}
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)