Interface CheckpointFailureManager.FailJobCallback

  • Enclosing class:
    CheckpointFailureManager

    public static interface CheckpointFailureManager.FailJobCallback
    A callback interface about how to fail a job.
    • 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.