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)