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/15 08:18:00 UTC

[jira] [Closed] (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 closed FLINK-25982.
------------------------------------
    Fix Version/s: 1.15.0
       Resolution: Implemented

Implemented in 0b1ae18769fb5774d8f42ce5610b26270e1b9fd7

> 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
>              Labels: pull-request-available
>             Fix For: 1.15.0
>
>
> 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)