Hi Anil,
When we trigger a savepoint, the JobManager's CheckpointCoordinator will
send an akka message for triggering to all source tasks,
which will generate a barrier for the savepoint (checkpoint).
I don't know if this explanation is clear enough.
Thanks, vino.
Anil 于2018年10月22日周一 下午2:21写道：
I think I didn't make myself clear. Sorry.
What I want to know is, when we trigger the savepoint, which checkpoint
barrier will it consider to trigger the savepoint.
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
Hi Anil,
When you manually trigger a savepoint, it is clear that it will wait for
the savepoint to complete.
Of course, the behavior of savepoint is consistent with checkpoint.
Thanks, vino.
Anil 于2018年10月22日周一 下午1:16写道：
> A checkpoint is completed when the nth the checkpoint barrier crosses t
A checkpoint is completed when the nth the checkpoint barrier crosses the
last operator.
When we trigger a savepoint manually, which checkpoint barrier is
considered.
Is it the next checkpoint barrier(next relative to the last barrier that was
considered to create the last checkpoint or savepoint
