[ 
https://issues.apache.org/jira/browse/FLINK-33395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Jane Chan updated FLINK-33395:
------------------------------
    Fix Version/s: 1.17.2
                   1.19.0
                   1.18.1

> The join hint doesn't work when appears in subquery
> ---------------------------------------------------
>
>                 Key: FLINK-33395
>                 URL: https://issues.apache.org/jira/browse/FLINK-33395
>             Project: Flink
>          Issue Type: Bug
>          Components: Table SQL / Planner
>    Affects Versions: 1.16.0, 1.17.0, 1.18.0
>            Reporter: xuyang
>            Assignee: xuyang
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: 1.17.2, 1.19.0, 1.18.1
>
>
> See the existent test 
> 'NestLoopJoinHintTest#testJoinHintWithJoinHintInCorrelateAndWithAgg', the 
> test plan is 
> {code:java}
> HashJoin(joinType=[LeftSemiJoin], where=[=(a1, EXPR$0)], select=[a1, b1], 
> build=[right], tryDistinctBuildRow=[true])
> :- Exchange(distribution=[hash[a1]])
> :  +- TableSourceScan(table=[[default_catalog, default_database, T1]], 
> fields=[a1, b1])
> +- Exchange(distribution=[hash[EXPR$0]])
>    +- LocalHashAggregate(groupBy=[EXPR$0], select=[EXPR$0])
>       +- Calc(select=[EXPR$0])
>          +- HashAggregate(isMerge=[true], groupBy=[a1], select=[a1, 
> Final_COUNT(count$0) AS EXPR$0])
>             +- Exchange(distribution=[hash[a1]])
>                +- LocalHashAggregate(groupBy=[a1], select=[a1, 
> Partial_COUNT(a2) AS count$0])
>                   +- NestedLoopJoin(joinType=[InnerJoin], where=[=(a2, a1)], 
> select=[a2, a1], build=[right])
>                      :- TableSourceScan(table=[[default_catalog, 
> default_database, T2, project=[a2], metadata=[]]], fields=[a2], 
> hints=[[[ALIAS options:[T2]]]])
>                      +- Exchange(distribution=[broadcast])
>                         +- TableSourceScan(table=[[default_catalog, 
> default_database, T1, project=[a1], metadata=[]]], fields=[a1], 
> hints=[[[ALIAS options:[T1]]]]) {code}
> but the NestedLoopJoin should broadcase left side.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to