Sure, this feature has been implemented in FLINK-12364 [1], all you need do is set the tolerable checkpoint failure numbers via like
env.getCheckpointConfig().setTolerableCheckpointFailureNumber(5); [1] https://issues.apache.org/jira/browse/FLINK-12364 Best Yun Tang From: "[email protected]" <[email protected]> Reply-To: "[email protected]" <[email protected]> Date: Monday, November 4, 2019 at 12:02 PM To: "[email protected]" <[email protected]> Subject: Checkpoint failed all the time Checkpoint will fail for some reasons， Is there a way to make checkpoint fail a certain number of times and then the job will fail automatically [cid:[email protected]]
