You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Jeyhun Karimov (JIRA)" <ji...@apache.org> on 2016/02/01 11:56:40 UTC

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

     [ 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)