Hi Dan, Have you use a too large upperBound or lowerBound?
If not, could you also check the watermark strategy ? The interval join operator depends on the event-time timer for cleanup, and the event-time timer would be triggered via watermark. Best, Yun ------------------Original Mail ------------------ Sender:Dan Hill <quietgol...@gmail.com> Send Date:Mon Mar 8 14:59:48 2021 Recipients:user <user@flink.apache.org> Subject:Gradually increasing checkpoint size Hi! I'm running a backfill Flink stream job over older data. It has multiple interval joins. I noticed my checkpoint is regularly gaining in size. I'd expect my checkpoints to stabilize and not grow. Is there a setting to prune useless data from the checkpoint? My top guess is that my checkpoint has a bunch of useless state in it. - Dan
