-
Type:
Bug
-
Status: Closed
-
Priority:
Major
-
Resolution: Fixed
-
Affects Version/s: 1.10.1, 1.11.0
-
Component/s: API / Python
-
Labels:
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.
- links to