public interface ExecutionStatusListener
Modifier and Type | Method and Description |
---|---|
void |
executionStatusChanged(JobID jobID,
JobVertexID vertexID,
String taskName,
int totalNumberOfSubTasks,
int subtaskIndex,
ExecutionAttemptID executionID,
ExecutionState newExecutionState,
long timestamp,
String optionalMessage)
Called whenever the execution status of a task changes.
|
void executionStatusChanged(JobID jobID, JobVertexID vertexID, String taskName, int totalNumberOfSubTasks, int subtaskIndex, ExecutionAttemptID executionID, ExecutionState newExecutionState, long timestamp, String optionalMessage)
jobID
- The ID of the jobvertexID
- The ID of the task vertextaskName
- The name of the tasktotalNumberOfSubTasks
- The parallelism of the tasksubtaskIndex
- The subtask's parallel indexexecutionID
- The ID of the execution attemptnewExecutionState
- The status to which the task switchedtimestamp
- The timestamp when the change occurred. Informational only.optionalMessage
- An optional message attached to the status change, like an
exception message.Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.