public interface TaskManagerActions
Task
with the TaskExecutor
.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.
|
void notifyFatalError(String message, Throwable cause)
message
- Message to reportcause
- Cause of the fatal errorvoid failTask(ExecutionAttemptID executionAttemptID, Throwable cause)
executionAttemptID
- Execution attempt ID of the task to failcause
- Cause of the failurevoid updateTaskExecutionState(TaskExecutionState taskExecutionState)
taskExecutionState
- Task execution state updateCopyright © 2014–2020 The Apache Software Foundation. All rights reserved.