You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/07/21 08:23:20 UTC

[jira] [Created] (FLINK-4239) Set Default Allowed Lateness to Zero and Make Triggers Non-Purging

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)