Hi Gurus,

I need to understand the checkpoint logic of the Dataflow Runner, like when
and how will the runner trigger a finalize on a checkpoint, is the finalize
thread same as the reader thread?

Could you share me the information, or point me to the related source code,
thanks in advance!

Island Chen

Reply via email to