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-6118) Chained operators forward watermark without checking
Date Sun, 19 Mar 2017 20:06:41 GMT
Aljoscha Krettek created FLINK-6118:

             Summary: Chained operators forward watermark without checking
                 Key: FLINK-6118
                 URL: https://issues.apache.org/jira/browse/FLINK-6118
             Project: Flink
          Issue Type: Bug
    Affects Versions: 1.1.4, 1.2.0, 1.3.0
            Reporter: Aljoscha Krettek

For operators that read from the network we have checks in place that verify that the input
watermark only moves forwards. If an operator is directly chained to an operator then any
{{Output.emitWatermark()}} of the first operator directly invoke {{processWatermark()}} on
the chained operator, meaning that there are no verification steps in-between.

This only becomes visible when a non-keyed, chained operator is checking the  current operator.
Only keyed operators can have timers and for those the watermark always comes form the network,
i.e. it behaves correctly.

This message was sent by Atlassian JIRA

View raw message