flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Aljoscha Krettek (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-4239) Set Default Allowed Lateness to Zero and Make Triggers Non-Purging
Date Thu, 21 Jul 2016 08:23:20 GMT
Aljoscha Krettek created FLINK-4239:
---------------------------------------

             Summary: Set Default Allowed Lateness to Zero and Make Triggers Non-Purging
                 Key: FLINK-4239
                 URL: https://issues.apache.org/jira/browse/FLINK-4239
             Project: Flink
          Issue Type: Sub-task
          Components: Streaming
    Affects Versions: 1.1.0
            Reporter: Aljoscha Krettek
            Assignee: Aljoscha Krettek


In preparation for upcoming changes in 1.2 we should set the default allowed lateness to zero
and make all built-in triggers non-purging by default. 

Currently, {{EventTimeTrigger}} and {{ProcessingTimeTrigger}} purge when they fire. This leads
to unexpected behavior when a user sets some meaningful allowed lateness. The behavior will
be that the window is purged when firing and the state will not actually be kept within the
allowed lateness.

Changing the behavior to non-purging requires changing the default allowed lateness from {{Long.MAX_VALUE}}
to {{0}}. Otherwise we would have memory leaks.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message