[ 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)