Hi Alexis, No, aligned checkpoint will not contain the in-flight. Aligned checkpoint makes sure that the data before the barrier has been processed and there is no need to store in-flight data for one checkpoint.
I think these documents[1][2] will help you to understand it. Best, Hang [1] https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/ops/state/checkpointing_under_backpressure/ [2] https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/concepts/stateful-stream-processing/#checkpointing Alexis Sarda-Espinosa <sarda.espin...@gmail.com> 于2023年2月11日周六 06:00写道： > Hello, > > One feature of unaligned checkpoints is that the checkpoint barriers can > overtake in-flight data, so the buffers are persisted as part of the state. > > The documentation for savepoints doesn't mention anything explicitly, so > just to be sure, will savepoints always wait for in-flight data to be > processed before they are completed, or could they also persist buffers in > certain situations (e.g. when there's backpressure)? > > Regards, > Alexis. > >
