ProcessFunction's Event Timer not firing

Posted by Fritz Budiyanto on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/ProcessFunction-s-Event-Timer-not-firing-tp24367.html

Hi All,

I noticed if one of the slot's watermark not progressing, its impacting all slots processFunction timer and no timer are not firing.

In my example, I have Source parallelism set to 8 and Kafka partition is 4. The next operator is processFunction with parallelism of 8 +  event timer. I can see from the debug log that one of the slot's watermark is not progressing. As a result, all slot's timer in the process function are not firing. Is this expected behavior or issue? How do I prevent this condition?

Thanks,
Fritz