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
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)
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

View raw message