You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2022/02/11 12:15:00 UTC

[jira] [Assigned] (FLINK-25982) Support idleness with watermark alignment

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

Dawid Wysakowicz reassigned FLINK-25982:
----------------------------------------

    Assignee: Dawid Wysakowicz

> 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
>            Assignee: Dawid Wysakowicz
>            Priority: Major
>
> In the PoC idleness is ignored. What it means is that even if all splits are idle, probably the last emitted watermark will be kept reported to the coordinator blocking all of the remaining source operators from making progress.



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