org.apache.flink.runtime.taskmanager

Interface TaskManagerActions

public interface TaskManagerActions

Interface for the communication of the Task with the TaskExecutor.

Method Summary

Modifier and Type	Method and Description
void	failTask(ExecutionAttemptID executionAttemptID, Throwable cause) Tells the task manager to fail the given task.
void	notifyFatalError(String message, Throwable cause) Notifies the task manager about a fatal error occurred in the task.
void	updateTaskExecutionState(TaskExecutionState taskExecutionState) Notifies the task manager about the task execution state update.

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