[
https://issues.apache.org/jira/browse/FLINK-31491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ran Tao updated FLINK-31491:
----------------------------
Summary: Flink table planner NestedLoopJoinTest.testLeftOuterJoinWithFilter
failed in branch release1.16 (was: table planner
NestedLoopJoinTest.testLeftOuterJoinWithFilter failed in branch release1.16)
> Flink table planner NestedLoopJoinTest.testLeftOuterJoinWithFilter failed in
> branch release1.16
> -----------------------------------------------------------------------------------------------
>
> Key: FLINK-31491
> URL: https://issues.apache.org/jira/browse/FLINK-31491
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Planner
> Reporter: Ran Tao
> Priority: Major
>
> branch release1.16 NestedLoopJoinTest.testLeftOuterJoinWithFilter failed.
> Mar 16 12:30:00 [ERROR] Failures:
> Mar 16 12:30:00 [ERROR] NestedLoopJoinTest.testLeftOuterJoinWithFilter1:37
> optimized exec plan expected:<...[InnerJoin], where=[[true], select=[a, e,
> f], build=[left])
> Mar 16 12:30:00 :- Exchange(distribution=[broadcast])
> Mar 16 12:30:00 : +- Calc(select=[a], where=[(a = 10)])
> Mar 16 12:30:00 : +- LegacyTableSourceScan(table=[[default_catalog,
> default_database, MyTable1, source: [TestTableSource(a, b, c)]]], fields=[a,
> b, c])
> Mar 16 12:30:00 +- Calc(select=[e, f], where=[(d = 10])])
> Mar 16 12:30:00 +- LegacyT...> but was:<...[InnerJoin], where=[[(a =
> d)], select=[a, d, e, f], build=[left])
> Mar 16 12:30:00 :- Exchange(distribution=[broadcast])
> Mar 16 12:30:00 : +- Calc(select=[a], where=[SEARCH(a, Sarg[10])])
> Mar 16 12:30:00 : +- LegacyTableSourceScan(table=[[default_catalog,
> default_database, MyTable1, source: [TestTableSource(a, b, c)]]], fields=[a,
> b, c])
> Mar 16 12:30:00 +- Calc(select=[d, e, f], where=[SEARCH(d, Sarg[10]])])
> Mar 16 12:30:00 +- LegacyT...>
> at
> org.apache.flink.table.planner.utils.DiffRepository.assertEquals(DiffRepository.java:438)
> at
> org.apache.flink.table.planner.utils.TableTestUtilBase.assertEqualsOrExpand(TableTestBase.scala:1075)
> at
> org.apache.flink.table.planner.utils.TableTestUtilBase.assertPlanEquals(TableTestBase.scala:1008)
> at
> org.apache.flink.table.planner.utils.TableTestUtilBase.doVerifyPlan(TableTestBase.scala:849)
> at
> org.apache.flink.table.planner.utils.TableTestUtilBase.verifyExecPlan(TableTestBase.scala:636)
> at
> org.apache.flink.table.planner.plan.batch.sql.join.NestedLoopJoinTest.testLeftOuterJoinWithFilter1(NestedLoopJoinTest.scala:37)
>
> azure ci:
> [https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=47244&view=logs&j=0c940707-2659-5648-cbe6-a1ad63045f0a&t=075c2716-8010-5565-fe08-3c4bb45824a4]
> And it can be reproduced in local. I think the caused commit may be:
> f0361c720cb18c4ae7dc669c6a5da5b09bc8f563
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
