Interface CheckpointFailureManager.FailJobCallback
-
- Enclosing class:
- CheckpointFailureManager
public static interface CheckpointFailureManager.FailJobCallback
A callback interface about how to fail a job.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
failJob(Throwable cause)
Fails the whole job graph.void
failJobDueToTaskFailure(Throwable cause, ExecutionAttemptID failingTask)
Fails the whole job graph due to task failure.
-
-
-
Method Detail
-
failJob
void failJob(Throwable cause)
Fails the whole job graph.- Parameters:
cause
- The reason why the synchronous savepoint fails.
-
failJobDueToTaskFailure
void failJobDueToTaskFailure(Throwable cause, ExecutionAttemptID failingTask)
Fails the whole job graph due to task failure.- Parameters:
cause
- The reason why the job is cancelled.failingTask
- The id of the failing task attempt to prevent failing the job multiple times.
-
-