Hi, you should expect that the size can vary for some checkpoints, even if the change rate is constant. Some checkpoints will upload compacted replacements for previous checkpoints to prevent that the checkpoint history will grow without bounds. Whenever that happens, the checkpoint does some „extra work“ by re-uploading compacted/merged versions of previous deltas.
Best, Stefan > Am 05.09.2018 um 22:29 schrieb burgesschen <tchen...@bloomberg.net>: > > Hi guys, > I enabled incremental flink checkpoint for my flink job. I had the job read > messages at a stable rate. For each message, the flink job store something > in the keyed state. My question is: For every minute, the increased state > size is the same, shouldn't the incremental checkpoint size remain > relatively constant also? How come it is increasing as shown in the picture? > Thank you! > > > <http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/file/t969/incremental_check_point.png> > > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
