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

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.10.1, 1.11.0
• Fix Version/s: 1.12.0, 1.10.3, 1.11.3
• Component/s: API / Python
• Labels: pull-request-available
• Assignee: Dian Fu
• Reporter: Dian Fu
• Created: 16/Oct/20 10:17
• Updated: 23/Oct/20 06:46
• Resolved: 23/Oct/20 06:46

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.

Issue Links

• links to: GitHub Pull Request #13746