Re: Low Watermark

[Piotr Nowojski]

Hi,

It's the minimal watermark among all 10 parallel instances of that Task.

Using metric (currentInputWatermark) [1] you can access the watermark of
each of those 10 sub tasks individually.

Best,
Piotrek

[1] https://nightlies.apache.org/flink/flink-docs-master/docs/ops/metrics/

pt., 25 lut 2022 o 14:10 Isidoros Ioannou  napisał(a):

> Hello, could someone please explain what the Low Watermark indicates in
> the Flink UI in the attached image?
> I have event time enabled with a boundOutOfOrdernessStrategy of 3s for the
> incoming events and I use CEP with a within window of 5 minutes.
>

Low Watermark

[Isidoros Ioannou]

Hello, could someone please explain what the Low Watermark indicates in the
Flink UI in the attached image?
I have event time enabled with a boundOutOfOrdernessStrategy of 3s for the
incoming events and I use CEP with a within window of 5 minutes.

Low Watermark: No Watermark

[Elias Levy]

Any reason the web UI would show No Watermark for the Low Watermark of a
job?  The job is using a punctuated timestamp assigner with watermarks, and
as far as I can tell it is generating watermarks properly.