[FLINK-4395] Eager processing of late arrivals in CEP operator

• Type: Improvement
• Status: Closed
• Priority: Minor
• Resolution: Invalid
• Component/s: Library / CEP
• Assignee: Ivan Mushketyk
• Reporter: Till Rohrmann
• Created: 15/Aug/16 07:58
• Updated: 09/May/17 09:01
• Resolved: 03/May/17 10:11

Description

At the moment elements are only processed after the CEP operator has received a watermark larger than the elements (in EventTime mode). In case of late arrivals this means that the late elements are not processed until the next watermark has arrived.

In order to decrease the latency for this scenario, I propose to eagerly process late arrivals in the CEP operator.

Issue Links

• links to: GitHub Pull Request #2396