[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Question about checkpoint logic of the Dataflow Runner

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