[jira] [Created] (FLINK-7005) Optimization steps are missing for nested registered tables

[Shang Yuanchun (Jira)]

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)