Hi, We have a class that extends KeyedProcessFunction and overrides onTimer() method. During processElement(), we register a timer callback using context.timerService().registerProcessingTimeTimer(<some-future-time>). For a while, we see that the onTimer() method is getting called back and everything works as expected; however, after a while, the onTimer() stops getting any callbacks from Flink (the registration of the timer via. registerProcessingTimeTimer() is working just fine). Does anyone know what could be wrong here and how we can debug this?
Flink version is 1.13.2 (running on AWS KDA) Thanks!
