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
