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)
