[ https://issues.apache.org/jira/browse/FLINK-2870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15125217#comment-15125217 ]
Shikhar Bhushan commented on FLINK-2870: ---------------------------------------- What is the current behaviour if a late element arrives and what kind of customization is possible? > Add support for accumulating/discarding for Event-Time Windows > -------------------------------------------------------------- > > Key: FLINK-2870 > URL: https://issues.apache.org/jira/browse/FLINK-2870 > Project: Flink > Issue Type: Sub-task > Components: Streaming > Reporter: Aljoscha Krettek > Assignee: Aljoscha Krettek > > This would allow to specify whether windows should be discarded after the > trigger fires or kept in the operator if late elements arrive. > When keeping elements, the user would also have to specify an allowed > lateness time after which the window contents are discarded without emitting > any further window evaluation result. > If elements arrive after the allowed lateness they would trigger the window > immediately with only the one single element. -- This message was sent by Atlassian JIRA (v6.3.4#6332)