[
https://issues.apache.org/jira/browse/FLINK-3177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeyhun Karimov reassigned FLINK-3177:
-------------------------------------
Assignee: 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
> Assignee: Jeyhun Karimov
>
> 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)
