[jira] [Closed] (FLINK-32321) Temporal Join job missing condition after “ON”

["macdoor615 (Jira)" <ji...@apache.org>]

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

macdoor615 closed FLINK-32321.
------------------------------
    Resolution: Fixed

> Temporal Join job missing condition after “ON”
> ----------------------------------------------
>
>                 Key: FLINK-32321
>                 URL: https://issues.apache.org/jira/browse/FLINK-32321
>             Project: Flink
>          Issue Type: Bug
>          Components: Table SQL / Gateway
>    Affects Versions: 1.18.0, 1.17.1
>            Reporter: macdoor615
>            Priority: Major
>
> We have a SQL job, like this
> {code:java}
> select ... from prod_kafka.f_alarm_tag_dev
>  /*+ OPTIONS('scan.startup.mode' = 'latest-offset') */ as f 
> left join mysql_bnpmp.gem_bnpmp.f_a_alarm_filter
>  /*+ OPTIONS('lookup.cache.max-rows' = '5000',
>  'lookup.cache.ttl' = '30s') */
> FOR SYSTEM_TIME AS OF f.proctime ff  on ff.rule_type = 0 and f.ne_ip = ff.ip {code}
> We submit to flink 1.17.1 & 1.18 rc2 cluster with sql-gateway. We found job detail missing lookup condition (rule_type=0) 
> {code:java}
>   +- [1196]:LookupJoin(table=[mysql_bnpmp.gem_bnpmp.f_a_alarm_filter], joinType=[LeftOuterJoin], lookup=[ip=ne_ip], select=[event_id, {code}
> We submit same sql to flink 1.17.0 cluster with sql-gateway. There is (rule_type=0) lookup condition
> {code:java}
>   +- [3]:LookupJoin(table=[mysql_bnpmp.gem_bnpmp.f_a_alarm_filter], joinType=[LeftOuterJoin], lookup=[rule_type=0, ip=ne_ip], where=[(rule_type = 0)], select=[event_id, severity,{code}
>  



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