[jira] [Updated] (FLINK-36869) Introduce TemporalRowTimeJoinOperator in TemporalJoin with Async State API

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

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

Weijie Guo updated FLINK-36869:
-------------------------------
    Affects Version/s: 2.1.0

> Introduce TemporalRowTimeJoinOperator in TemporalJoin with Async State API
> --------------------------------------------------------------------------
>
>                 Key: FLINK-36869
>                 URL: https://issues.apache.org/jira/browse/FLINK-36869
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Table SQL / Runtime
>    Affects Versions: 2.1.0
>            Reporter: Wang Qilong
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: 2.0.0
>
>
> As long as the Asynchronous StateTemporalRowTimeJoinOperator uses the V2 version of ValueState, whether using the sync or asynchronous method of ValueState, it will result in the inability to trigger onEventTime(), that is, the timer registered in timerService. registrant EventTimeTimeTimeTimeTime() cannot successfully change to the fired state
> Perhaps might think it's due to the asynchronous code I wrote, but even if all APIs use the V2 version of the sync API, there will still be the aforementioned issue (i.e. not modifying any implementation code, only replacing the V1 version's valueState with the V2 version)
> Because the event time can be defined before it is processed, the asynchronous version of TemporalRowTimeJoin should also be implemented, but a similar solution has not been found, so mark is here
> The specific code can be seen [https://github.com/Au-Miner/flink/tree/FLINK-36869]



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