[jira] [Created] (FLINK-3177) Add Stream Operator that Discards Late Elements

[Shang Yuanchun (Jira)]

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)