[
https://issues.apache.org/jira/browse/FLINK-36823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36823:
-----------------------------------
Labels: pull-request-available (was: )
> Drain state requests after the user function perform snapshotState
> ------------------------------------------------------------------
>
> Key: FLINK-36823
> URL: https://issues.apache.org/jira/browse/FLINK-36823
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / Checkpointing
> Reporter: Zakelly Lan
> Assignee: Zakelly Lan
> Priority: Major
> Labels: pull-request-available
>
> Currently, the user function of {{KeyedProcessOperator}} would manipulate
> state in {{snapshotState}} (e.g. flush cache into state), which should be
> included in the checkpoint. So we should drain these state requests before
> snapshot the keyed state.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
