Hi Sohimankotia, you can control Flink's failure behaviour in case of a checkpoint failure via the `ExecutionConfig#setFailTaskOnCheckpointError(boolean)`. Per default it is set to true which means that a Flink task will fail if a checkpoint error occurs. If you set it to false, then the job won't fail if a checkpoint fails.
Cheers, Till On Wed, Jan 16, 2019 at 3:20 AM Congxian Qiu <qcx978132...@gmail.com> wrote: > Hi, Sohi > You can check out doc[1][2] to find out the answer. > > [1] > https://ci.apache.org/projects/flink/flink-docs-release-1.7/dev/stream/state/checkpointing.html#enabling-and-configuring-checkpointing > [2] > https://ci.apache.org/projects/flink/flink-docs-release-1.7/dev/restart_strategies.html > > sohimankotia <sohimanko...@gmail.com> 于2019年1月15日周二 下午4:16写道： > >> Yes. File got deleted . >> >> 2019-01-15 10:40:41,360 INFO FSNamesystem.audit: allowed=true ugi=hdfs >> (auth:SIMPLE) ip=/192.168.3.184 cmd=delete >> src=/pipeline/job/checkpoints/e9a08c0661a6c31b5af540cf352e1265/chk-470/5fb3a899-8c0f-45f6-a847-42cbb71e6d19 >> >> dst=null perm=null proto=rpc >> >> Looks like file was deleted from job itself . >> >> Does it cause job restart then ? >> >> If checkpoint fails then it should try next checkpoint or restart job ? >> >> >> >> >> >> >> -- >> Sent from: >> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ >> > > > -- > Best, > Congxian >
