public class ActorGatewayTaskManagerActions extends Object implements TaskManagerActions
ActorGateway
to forward the messages.Constructor and Description |
---|
ActorGatewayTaskManagerActions(ActorGateway actorGateway) |
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.
|
public ActorGatewayTaskManagerActions(ActorGateway actorGateway)
public void notifyFatalError(String message, Throwable cause)
TaskManagerActions
notifyFatalError
in interface TaskManagerActions
message
- Message to reportcause
- Cause of the fatal errorpublic void failTask(ExecutionAttemptID executionAttemptID, Throwable cause)
TaskManagerActions
failTask
in interface TaskManagerActions
executionAttemptID
- Execution attempt ID of the task to failcause
- Cause of the failurepublic void updateTaskExecutionState(TaskExecutionState taskExecutionState)
TaskManagerActions
updateTaskExecutionState
in interface TaskManagerActions
taskExecutionState
- Task execution state updateCopyright © 2014–2020 The Apache Software Foundation. All rights reserved.