org.apache.flink.runtime.taskmanager

Class TaskExecutionState

java.lang.Object

org.apache.flink.runtime.taskmanager.TaskExecutionState

All Implemented Interfaces:

Serializable

public class TaskExecutionState
extends Object
implements Serializable

This class represents an update about a task's execution state. NOTE: The exception that may be attached to the state update is not necessarily a Flink or core Java exception, but may be an exception from the user code. As such, it cannot be deserialized without a special class loader. For that reason, the class keeps the actual exception field transient and deserialized it lazily, with the appropriate class loader.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
TaskExecutionState(org.apache.flink.api.common.JobID jobID, ExecutionAttemptID executionId, ExecutionState executionState) Creates a new task execution state update, with no attached exception.
TaskExecutionState(org.apache.flink.api.common.JobID jobID, ExecutionAttemptID executionId, ExecutionState executionState, Throwable error) Creates a new task execution state update, with an attached exception.

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object obj)
Throwable	getError(ClassLoader usercodeClassloader) Gets the attached exception.
ExecutionState	getExecutionState() Returns the new execution state of the task.
ExecutionAttemptID	getID() Returns the ID of the task this result belongs to
org.apache.flink.api.common.JobID	getJobID() The ID of the job the task belongs to
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

TaskExecutionState

public TaskExecutionState(org.apache.flink.api.common.JobID jobID,
                          ExecutionAttemptID executionId,
                          ExecutionState executionState)

Creates a new task execution state update, with no attached exception.

Parameters:

jobID - the ID of the job the task belongs to

executionId - the ID of the task execution whose state is to be reported

executionState - the execution state to be reported

TaskExecutionState

public TaskExecutionState(org.apache.flink.api.common.JobID jobID,
                          ExecutionAttemptID executionId,
                          ExecutionState executionState,
                          Throwable error)

Creates a new task execution state update, with an attached exception. This constructor may never throw an exception.

Parameters:

jobID - the ID of the job the task belongs to

executionId - the ID of the task execution whose state is to be reported

executionState - the execution state to be reported

error - an optional error

Method Detail

getError

public Throwable getError(ClassLoader usercodeClassloader)

Gets the attached exception. Requires to pass a classloader, because the class of the exception may be user-defined and hence only accessible through the user code classloader, not the default classloader.

Parameters:

usercodeClassloader - The class loader for the user code of the job this update refers to.

getID

public ExecutionAttemptID getID()

Returns the ID of the task this result belongs to

Returns:

the ID of the task this result belongs to

getExecutionState

public ExecutionState getExecutionState()

Returns the new execution state of the task.

Returns:

the new execution state of the task

getJobID

public org.apache.flink.api.common.JobID getJobID()

The ID of the job the task belongs to

Returns:

the ID of the job the task belongs to

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object