Zakelly Lan created FLINK-36928:
-----------------------------------
Summary: Split the action of Epoch into two parts (trigger & final)
Key: FLINK-36928
URL: https://issues.apache.org/jira/browse/FLINK-36928
Project: Flink
Issue Type: Sub-task
Components: Runtime / Async State Processing
Reporter: Zakelly Lan
Assignee: Zakelly Lan
We have introduced the `EpochManager` to handle the watermark during async
state processing. The inputs are divided into several epochs where a action is
attached and triggered after all the inputs finished their async processing.
However, the action itself may trigger more async procedures which blocks some
synchronous action. Thus it is better to introduce two types of action, one is
for triggered right after all the inputs finished, while another is for being
triggered after all the async processing including the ones from the action
finished.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
