flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Jeyhun Karimov (JIRA)" <j...@apache.org>
Subject [jira] [Assigned] (FLINK-3177) Add Stream Operator that Discards Late Elements
Date Fri, 29 Jan 2016 15:55:39 GMT

     [ 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

View raw message