Piotr Nowojski created FLINK-8589:
-------------------------------------
Summary: 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
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)