[jira] [Updated] (FLINK-36928) Split the action of Epoch into two parts (trigger & final)

["ASF GitHub Bot (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-36928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

ASF GitHub Bot updated FLINK-36928:
-----------------------------------
    Labels: pull-request-available  (was: )

> 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
>            Priority: Major
>              Labels: pull-request-available
>
> 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)