flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Till Rohrmann (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-4395) Eager processing of late arrivals in CEP operator
Date Mon, 15 Aug 2016 07:59:20 GMT
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

View raw message