Hi,
Your example does not show what watermarks are flowing through the
program. It prints the watermark at the point a record is being emitted.
As the cited text states, the final watermark is emitted after all
records are emitted. You can test it e.g. with the newly added
writeWatermark method in
Hi,
According to the docs [1]
When a source reaches the end of the input, it emits a final watermark with
timestamp Long.MAX_VALUE, indicating the "end of time".
However, in my small experiment [2], the Flink job reads from a local csv
file, and prints a watermark for each record in the SinkFun
