[
https://issues.apache.org/jira/browse/FLINK-36715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18004325#comment-18004325
]
Qilong Wang commented on FLINK-36715:
-------------------------------------
Hi [~Sergey Nuyanzin], at present, the issue cannot be reproduced. It seems
that the problem has been fixed by PrunEmptyRules.
```
util.addTableSource[(Long, Int, String)]("src1", 'k, 'v)
util.addTableSource[(Long, Int, String)]("src2", 'k, 'v)
val sql =
"""
|SELECT * FROM
| (SELECT * FROM src1 WHERE k = 0) src1
|LEFT OUTER JOIN
| (SELECT * from src2 WHERE k = 0) src2
|ON (src1.k = src2.k AND src2.k > 10)
|""".stripMargin
util.verifyExecPlan(sql)
```
> Changed behavior for filter push down for IS NOT DISTINCT FROM after Calcite
> upgrade to 1.33
> ---------------------------------------------------------------------------------------------
>
> Key: FLINK-36715
> URL: https://issues.apache.org/jira/browse/FLINK-36715
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / API, Table SQL / Planner
> Reporter: Sergey Nuyanzin
> Priority: Major
>
> After moving to 1.33 need to put RexUtil into Filnk repo to prevent a number
> of failures (more than 30)
> like
> {noformat}
> FlinkLogicalCalc(select=[CAST(0:BIGINT AS BIGINT) AS k, v, k AS k0, v0])
> +- FlinkLogicalJoin(condition=[true], joinType=[left])
> :- FlinkLogicalCalc(select=[v], where=[=(k, 0:BIGINT)])
> : +- FlinkLogicalLegacyTableSourceScan(table=[[default_catalog,
> default_database, src, source: [TestTableSource(k, v)]]], fields=[k, v])
> +- FlinkLogicalValues(type=[RecordType(BIGINT k, VARCHAR(2147483647) v)],
> tuples=[[]])
> This exception indicates that the query uses an unsupported SQL feature.
> Please check the documentation for the set of currently supported SQL
> features.
> {noformat}
> This is a result of https://issues.apache.org/jira/browse/CALCITE-5336
> the jira issue is to adapt Flink behavior and to remove RexUtil after that
> from Flink repo
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
