Re: In-flight data within aligned checkpoints/savepoints

2022-08-23 Thread Darin Amos via user
whether unaligned checkpoints are enabled by > configuration-tab [2]. > > [1] > https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/ops/monitoring/checkpoint_monitoring/#history-tab > [2] > https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/ops/monitoring/checkpoi

In-flight data within aligned checkpoints/savepoints

2022-08-22 Thread Darin Amos via user
Hi All! I am running Flink 1.13.1 and I have unaligned checkpoints disabled, however I often see my checkpoints contain "Processed (persisted) in-flight data". According to the Flink documentation, it states: - *Persisted in-flight data: The number of bytes persisted during the alignment (t

ContinuousFileReaderOperator from Kafka Source (Scala, Flink 1.13.1)

2022-06-22 Thread Darin Amos
erence to the Mailbox executor? Thanks! Darin Amos