Zakelly Lan created FLINK-36823:
-----------------------------------
Summary: 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
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)
