Aljoscha Krettek created FLINK-3177:
---------------------------------------
Summary: 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)
