public static interface CheckpointFailureManager.FailJobCallback
|Modifier and Type||Method and Description|
Fails the whole job graph.
Fails the whole job graph due to task failure.
void failJob(Throwable cause)
cause- The reason why the synchronous savepoint fails.
void failJobDueToTaskFailure(Throwable cause, ExecutionAttemptID failingTask)
cause- The reason why the job is cancelled.
failingTask- The id of the failing task attempt to prevent failing the job multiple times.
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.