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
