Hi all,

I'm using Flink 1.13 and my job is experiencing high start delay, more so
than high alignment time. (our flip 27 kafka source is heavily
backpressured). Since our alignment timeout is set to 1s, the unaligned
checkpoint never triggers since alignment delay is always below the
threshold.

It's seems there is only a configuration for alignment timeout but should
there also be one for start delay timeout:
https://nightlies.apache.org/flink/flink-docs-master/docs/ops/state/checkpointing_under_backpressure/#aligned-checkpoint-timeout

I'm interested to know the reasoning why there isn't a timeout for start
delay as well--was it because it was deemed too complex for the user to
configure two parameters for unaligned checkpoints?

I'm aware of buffer debloating in 1.14 that could help but I'm trying to
see how far unaligned checkpointing can take me.

Best,
Mason

Reply via email to