For those running Flink applications on AWS with the Kinesis Data Analytics 1.13.2 runtime, I have a job with a KeyedProcessFunction that registers a processing time timer in the processElement method.
The timer fires as expected when running unit tests with the test harness, when running the job in the LocalEnvironment, and as a JAR in a Flink docker cluster, but it does not fire when deployed as a KDA app on AWS. I see events being received by it in the job graph, but nothing is emitted. Any insight would be appreciated.