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