Hi! I would like to know more about the checkpoint mechanism when Beam pipelines are executed on Flink. I have been doing some testing around checkpoints and stuff and I’m having trouble understanding the results. I think I could do better with exact resources that would lead me to understand fault tolerant mechanisms, duplicate handling and so on.
Best Regards, Gayal Rupasinghe
