Hi Irakli,
If you see the watermarks tab on the operator do you see being propagated?
If for example your source has multiple splits (like Kafka partitions) if
one is idle or stays behind the watermark won’t be propagated as it is the
minimum from all inputs (partitions/splits)
Best
On Fri, 20
Hello,
I have a Flink application that is consuming events from the Kafka topic and
builds sessions from them. I'm using the Keyed stream. The application runs
fine initially, but after some time it is getting "stuck". I can see that the
"processElement" function is processing the incoming
