Hi Juho,
I think that neither a) nor b) hold.
The reported times are wall-clock times (or processing time in Flink
terminology) when the checkpoint
started and when it finished.
What you want, if I understand correctly, is these times to reflect the event
time of your pipeline. In other
wo
Hi,
I think a) doesn't hold because there is no synchronisation between the
CheckpointCoordinator and the sources doing the reading. I think b) will hold
but it's also not exact because of clock differences between different machines
and whatnot.
Best,
Aljoscha
> On 29. Jan 2018, at 15:34, Ju
