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

Posted to issues@flink.apache.org by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/02/19 14:17:00 UTC

[jira] [Closed] (FLINK-8589) Add data polling method to InputGate

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

Piotr Nowojski closed FLINK-8589.
---------------------------------
    Resolution: Fixed

> Add data polling method to InputGate
> ------------------------------------
>
>                 Key: FLINK-8589
>                 URL: https://issues.apache.org/jira/browse/FLINK-8589
>             Project: Flink
>          Issue Type: Sub-task
>            Reporter: Piotr Nowojski
>            Assignee: Piotr Nowojski
>            Priority: Major
>
> This is a preparation for changes in data notifications, which will not be
>  that strict as they are now. If we poll the data from InputGates in UnionInputGate instead of blockingly wait for them, we will be able to handle false data notifications that are inevitable in new flushing model.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)