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)