Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-7005

Optimization steps are missing for nested registered tables

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 1.3.0, 1.3.1
    • Fix Version/s: 1.4.0, 1.3.2
    • Component/s: Table API & SQL
    • Labels:
      None

      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]
      

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                twalthr Timo Walther
                Reporter:
                twalthr Timo Walther
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: