You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Wang Qilong (Jira)" <ji...@apache.org> on 2024/12/10 12:04:00 UTC
[jira] [Updated] (FLINK-36869) Introduce TemporalRowTimeJoinOperator in TemporalJoin with Async State API
[ https://issues.apache.org/jira/browse/FLINK-36869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Wang Qilong updated FLINK-36869:
--------------------------------
Description:
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 you 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
> 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
> 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 you 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)