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

Piotr Nowojski updated FLINK-25982:
-----------------------------------
    Description: In the PoC idleness is ignored. What it means that even if all 
splits are idle, probably the last emitted watermark will be kept reported to 
the coordinator probably causing blocking all of the remaining source operators.

> Support idleness with watermark alignment
> -----------------------------------------
>
>                 Key: FLINK-25982
>                 URL: https://issues.apache.org/jira/browse/FLINK-25982
>             Project: Flink
>          Issue Type: Sub-task
>            Reporter: Piotr Nowojski
>            Priority: Major
>
> In the PoC idleness is ignored. What it means that even if all splits are 
> idle, probably the last emitted watermark will be kept reported to the 
> coordinator probably causing blocking all of the remaining source operators.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

Reply via email to