You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/15 07:59:20 UTC
[jira] [Created] (FLINK-4395) Eager processing of late arrivals in
CEP operator
Till Rohrmann created FLINK-4395:
------------------------------------
Summary: Eager processing of late arrivals in CEP operator
Key: FLINK-4395
URL: https://issues.apache.org/jira/browse/FLINK-4395
Project: Flink
Issue Type: Improvement
Components: CEP
Reporter: Till Rohrmann
Priority: Minor
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.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)