[jira] [Created] (FLINK-6118) Chained operators forward watermark without checking

[Shang Yuanchun (Jira)]

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
(v6.3.15#6346)