[FLINK-2802] Watermark triggered operators cannot progress with cyclic flows

• Type: Bug
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: 0.10.0
• Component/s: API / DataStream
• Assignee: Gyula Fora
• Reporter: Gyula Fora
• Created: 02/Oct/15 08:24
• Updated: 28/Feb/19 11:14
• Resolved: 05/Oct/15 10:07

Description

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.