[FLINK-7005] Optimization steps are missing for nested registered tables

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.3.0, 1.3.1
• Fix Version/s: 1.3.2, 1.4.0
• Component/s: Table SQL / API
• Assignee: Timo Walther
• Reporter: Timo Walther
• Created: 26/Jun/17 10:35
• Updated: 27/Jun/17 13:15
• Resolved: 27/Jun/17 13:15

Description

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:

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]

Issue Links

• links to: GitHub Pull Request #4186