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)
