[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 ] Weijie Guo updated FLINK-36869: --- Fix Version/s: 2.1.0 (was: 2.0.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.1.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)
[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 ] 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)
[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 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)
[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)
