[
https://issues.apache.org/jira/browse/FLINK-3177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeyhun Karimov updated FLINK-3177:
----------------------------------
Assignee: (was: Jeyhun Karimov)
> Add Stream Operator that Discards Late Elements
> -----------------------------------------------
>
> Key: FLINK-3177
> URL: https://issues.apache.org/jira/browse/FLINK-3177
> Project: Flink
> Issue Type: Improvement
> Components: Streaming
> Reporter: Aljoscha Krettek
>
> We should introduce an operator (and API call on DataStream) that allows
> users to discard late elements (with respect to their timestamps and the
> current watermark). The operator could have two modes, one for silently
> discarding elements that are late and one for failing the job if late
> elements arrive (as a sort of sanity check).
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
