Hello,

I'm curious about how Flink checkpointing would aid in recovering data if
the data source is not Kafka but another system. I understand that
checkpoint snapshots are taken at regular time intervals.

What happens to the data that were read after the previous successful
checkpoint if the system crashes before the next checkpointing interval,
especially for data sources that are not Kafka and don't support offset
management?

-
JB

Reply via email to