flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Lorenzo Affetti <lorenzo.affe...@gmail.com>
Subject Issue on watermark meaning
Date Fri, 29 Jan 2016 09:49:54 GMT
Hi everybody,
I want to signal that I think there is a mismatch between what is the
meaning of emitting a watermark between the code and the documentation:

from Flink docs
<https://ci.apache.org/projects/flink/flink-docs-master/apis/streaming/index.html#working-with-time>:
A watermark with a certain timestamp denotes the knowledge that no event
with timestamp* lower than *the timestamp of the watermark will ever arrive.


from Flink code (Output.java)
<https://raw.githubusercontent.com/apache/flink/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/Output.java>
:
A watermark specifies that no element with a timestamp *older or equal* to
the watermark timestamp will be emitted in the future.

I think that the documentation should be fixed to match "lower or equal to"
because it is what the system really does, I think.

Thank you
-- 
Lorenzo Affetti

Mime
View raw message