Interface TaskManagerActions


  • public interface TaskManagerActions
    Interface for the communication of the Task with the TaskExecutor.
    • Method Detail

      • notifyFatalError

        void notifyFatalError​(String message,
                              Throwable cause)
        Notifies the task manager about a fatal error occurred in the task.
        Parameters:
        message - Message to report
        cause - Cause of the fatal error
      • failTask

        void failTask​(ExecutionAttemptID executionAttemptID,
                      Throwable cause)
        Tells the task manager to fail the given task.
        Parameters:
        executionAttemptID - Execution attempt ID of the task to fail
        cause - Cause of the failure
      • updateTaskExecutionState

        void updateTaskExecutionState​(TaskExecutionState taskExecutionState)
        Notifies the task manager about the task execution state update.
        Parameters:
        taskExecutionState - Task execution state update
      • notifyEndOfData

        void notifyEndOfData​(ExecutionAttemptID executionAttemptID)
        Notifies that the task has reached the end of data.
        Parameters:
        executionAttemptID - Execution attempt ID of the task.