[
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 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]
was:
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 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)
