[ 
https://issues.apache.org/jira/browse/FLINK-36936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17912729#comment-17912729
 ] 

xuyang edited comment on FLINK-36936 at 1/14/25 3:36 AM:
---------------------------------------------------------

Please note that we need to implement an additional map in the cache under the 
async state scenario to track data that has been removed from the cache but not 
yet updated by the async state API. This will help ensure consistency between 
the cache and the state data, preventing other keys from accessing stale or 
dirty data from state.

See more at https://github.com/apache/flink/pull/25723#discussion_r1909824008


was (Author: xuyangzhong):
Please note that we need to implement an additional map in the cache under the 
async state scenario to track data that has been removed from the cache but not 
yet updated by the async state API. This will help ensure consistency between 
the cache and the state data, preventing other keys from accessing stale or 
dirty data from state.

> Introduce UpdatableTopNFunction in Rank with Async State API
> ------------------------------------------------------------
>
>                 Key: FLINK-36936
>                 URL: https://issues.apache.org/jira/browse/FLINK-36936
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Table SQL / Runtime
>    Affects Versions: 2.0.0
>            Reporter: Wang Qilong
>            Priority: Major
>              Labels: pull-request-available
>




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

Reply via email to