flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Aljoscha Krettek (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-3177) Add Stream Operator that Discards Late Elements
Date Wed, 16 Dec 2015 10:34:46 GMT
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

View raw message