[ https://issues.apache.org/jira/browse/FLINK-2802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Maximilian Michels resolved FLINK-2802. --------------------------------------- Resolution: Fixed Fix Version/s: 0.10 As far as I understand this has been resolved. Resolving but feel free to reopen. > Watermark triggered operators cannot progress with cyclic flows > --------------------------------------------------------------- > > Key: FLINK-2802 > URL: https://issues.apache.org/jira/browse/FLINK-2802 > Project: Flink > Issue Type: Bug > Components: Streaming > Reporter: Gyula Fora > Assignee: Gyula Fora > Priority: Blocker > Fix For: 0.10 > > > The problem is that we can easily create a cyclic watermark (time) dependency > in the stream graph which will result in a deadlock for watermark triggered > operators such as the `WindowOperator`. > A solution to this could be to emit a Long.MAX_VALUE watermark from the > iteration sources. -- This message was sent by Atlassian JIRA (v6.3.4#6332)