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

The plan of is incorrect when Calc contains WHERE clause, composite fields access and Python UDF at the same time

    XMLWordPrintableJSON

    Details

      Description

      For the following job:

      SELECT a, pyFunc1(b, d._1) FROM MyTable WHERE a + 1 > 0
      

      The plan is as following:

      FlinkLogicalCalc(select=[a, pyFunc1(b, f0) AS EXPR$1])
      +- FlinkLogicalCalc(select=[a, b, d._1 AS f0])
       +- FlinkLogicalLegacyTableSourceScan(table=[[default_catalog, default_database, MyTable, source: [TestTableSource(a, b, c, d)]]], fields=[a, b, c, d])
      

      It's incorrect as the where condition is missing.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                dian.fu Dian Fu
                Reporter:
                dian.fu Dian Fu
              • Votes:
                0 Vote for this issue
                Watchers:
                1 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: