Re: keyby mapState use question

Hi, This should not happen. I guess the `onTimer` and `processElement` you are testing are triggered under different keyby keys. Note that the keyed states are partitioned by the keyby key first, so if querying or setting the state, you are only manipulating the specific partition which does not a

Re: Flink 1.18.0 Checkpoints on cancelled jobs

Hi Ethan, Looks like this got changed after https://issues.apache.org/jira/browse/FLINK-32469. Now the checkpoint history call throws below exception for canceled job. 2023-12-10 21:50:12,990 ERROR org.apache.flink.runtime.rest.handler.job.checkpoints. CheckpointingStatisticsHandler [] - Excepti