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 <anilsingh....@gmail.com> 于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/ >
