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 <akis3...@gmail.com> 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. >
