org.apache.flink.runtime.executiongraph

Class ArchivedExecutionGraph

java.lang.Object

org.apache.flink.runtime.executiongraph.ArchivedExecutionGraph

All Implemented Interfaces:

Serializable, AccessExecutionGraph

public class ArchivedExecutionGraph
extends Object
implements AccessExecutionGraph, Serializable

An archived execution graph represents a serializable form of the ExecutionGraph.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description

ArchivedExecutionGraph(JobID jobID, String jobName, Map<JobVertexID,ArchivedExecutionJobVertex> tasks, List<ArchivedExecutionJobVertex> verticesInCreationOrder, long[] stateTimestamps, JobStatus state, ErrorInfo failureCause, String jsonPlan, StringifiedAccumulatorResult[] archivedUserAccumulators, Map<String,SerializedValue<OptionalFailure<Object>>> serializedUserAccumulators, ArchivedExecutionConfig executionConfig, boolean isStoppable, CheckpointCoordinatorConfiguration jobCheckpointingConfiguration, CheckpointStatsSnapshot checkpointStatsSnapshot, String stateBackendName)

Method Summary

Modifier and Type	Method and Description
static ArchivedExecutionGraph	createFrom(ExecutionGraph executionGraph) Create a ArchivedExecutionGraph from the given ExecutionGraph.
StringifiedAccumulatorResult[]	getAccumulatorResultsStringified() Returns the aggregated user-defined accumulators as strings.
Map<String,SerializedValue<OptionalFailure<Object>>>	getAccumulatorsSerialized() Returns a map containing the serialized values of user-defined accumulators.
Iterable<ArchivedExecutionVertex>	getAllExecutionVertices() Returns an iterable containing all execution vertices for this execution graph.
Map<JobVertexID,AccessExecutionJobVertex>	getAllVertices() Returns a map containing all job vertices for this execution graph.
ArchivedExecutionConfig	getArchivedExecutionConfig() Returns the ArchivedExecutionConfig for this execution graph.
CheckpointCoordinatorConfiguration	getCheckpointCoordinatorConfiguration() Returns the CheckpointCoordinatorConfiguration or null if checkpointing is disabled.
CheckpointStatsSnapshot	getCheckpointStatsSnapshot() Returns a snapshot of the checkpoint statistics or null if checkpointing is disabled.
ErrorInfo	getFailureInfo() Returns the exception that caused the job to fail.
JobID	getJobID() Returns the JobID for this execution graph.
String	getJobName() Returns the job name for the execution graph.
ArchivedExecutionJobVertex	getJobVertex(JobVertexID id) Returns the job vertex for the given JobVertexID.
String	getJsonPlan() Returns the job plan as a JSON string.
JobStatus	getState() Returns the current JobStatus for this execution graph.
Optional<String>	getStateBackendName() Returns the state backend name for this ExecutionGraph.
long	getStatusTimestamp(JobStatus status) Returns the timestamp for the given JobStatus.
Iterable<ArchivedExecutionJobVertex>	getVerticesTopologically() Returns an iterable containing all job vertices for this execution graph in the order they were created.
boolean	isArchived() Returns whether this execution graph was archived.
boolean	isStoppable() Returns whether the job for this execution graph is stoppable.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ArchivedExecutionGraph

public ArchivedExecutionGraph(JobID jobID,
                              String jobName,
                              Map<JobVertexID,ArchivedExecutionJobVertex> tasks,
                              List<ArchivedExecutionJobVertex> verticesInCreationOrder,
                              long[] stateTimestamps,
                              JobStatus state,
                              @Nullable
                              ErrorInfo failureCause,
                              String jsonPlan,
                              StringifiedAccumulatorResult[] archivedUserAccumulators,
                              Map<String,SerializedValue<OptionalFailure<Object>>> serializedUserAccumulators,
                              ArchivedExecutionConfig executionConfig,
                              boolean isStoppable,
                              @Nullable
                              CheckpointCoordinatorConfiguration jobCheckpointingConfiguration,
                              @Nullable
                              CheckpointStatsSnapshot checkpointStatsSnapshot,
                              @Nullable
                              String stateBackendName)

Method Detail

getJsonPlan

public String getJsonPlan()

Description copied from interface: AccessExecutionGraph

Returns the job plan as a JSON string.

Specified by:

getJsonPlan in interface AccessExecutionGraph

Returns:

job plan as a JSON string

getJobID

public JobID getJobID()

Description copied from interface: AccessExecutionGraph

Returns the JobID for this execution graph.

Specified by:

getJobID in interface AccessExecutionGraph

Returns:

job ID for this execution graph

getJobName

public String getJobName()

Description copied from interface: AccessExecutionGraph

Returns the job name for the execution graph.

Specified by:

getJobName in interface AccessExecutionGraph

Returns:

job name for this execution graph

getState

public JobStatus getState()

Description copied from interface: AccessExecutionGraph

Returns the current JobStatus for this execution graph.

Specified by:

getState in interface AccessExecutionGraph

Returns:

job status for this execution graph

getFailureInfo

@Nullable
public ErrorInfo getFailureInfo()

Description copied from interface: AccessExecutionGraph

Returns the exception that caused the job to fail. This is the first root exception that was not recoverable and triggered job failure.

Specified by:

getFailureInfo in interface AccessExecutionGraph

Returns:

failure causing exception, or null

getJobVertex

public ArchivedExecutionJobVertex getJobVertex(JobVertexID id)

Description copied from interface: AccessExecutionGraph

Returns the job vertex for the given JobVertexID.

Specified by:

getJobVertex in interface AccessExecutionGraph

Parameters:

id - id of job vertex to be returned

Returns:

job vertex for the given id, or null

getAllVertices

public Map<JobVertexID,AccessExecutionJobVertex> getAllVertices()

Description copied from interface: AccessExecutionGraph

Returns a map containing all job vertices for this execution graph.

Specified by:

getAllVertices in interface AccessExecutionGraph

Returns:

map containing all job vertices for this execution graph

getVerticesTopologically

public Iterable<ArchivedExecutionJobVertex> getVerticesTopologically()

Description copied from interface: AccessExecutionGraph

Returns an iterable containing all job vertices for this execution graph in the order they were created.

Specified by:

getVerticesTopologically in interface AccessExecutionGraph

Returns:

iterable containing all job vertices for this execution graph in the order they were created

getAllExecutionVertices

public Iterable<ArchivedExecutionVertex> getAllExecutionVertices()

Description copied from interface: AccessExecutionGraph

Returns an iterable containing all execution vertices for this execution graph.

Specified by:

getAllExecutionVertices in interface AccessExecutionGraph

Returns:

iterable containing all execution vertices for this execution graph

getStatusTimestamp

public long getStatusTimestamp(JobStatus status)

Description copied from interface: AccessExecutionGraph

Returns the timestamp for the given JobStatus.

Specified by:

getStatusTimestamp in interface AccessExecutionGraph

Parameters:

status - status for which the timestamp should be returned

Returns:

timestamp for the given job status

getCheckpointCoordinatorConfiguration

public CheckpointCoordinatorConfiguration getCheckpointCoordinatorConfiguration()

Description copied from interface: AccessExecutionGraph

Returns the CheckpointCoordinatorConfiguration or null if checkpointing is disabled.

Specified by:

getCheckpointCoordinatorConfiguration in interface AccessExecutionGraph

Returns:

JobCheckpointingConfiguration for this execution graph

getCheckpointStatsSnapshot

public CheckpointStatsSnapshot getCheckpointStatsSnapshot()

Description copied from interface: AccessExecutionGraph

Returns a snapshot of the checkpoint statistics or null if checkpointing is disabled.

Specified by:

getCheckpointStatsSnapshot in interface AccessExecutionGraph

Returns:

Snapshot of the checkpoint statistics for this execution graph

isArchived

public boolean isArchived()

Description copied from interface: AccessExecutionGraph

Returns whether this execution graph was archived.

Specified by:

isArchived in interface AccessExecutionGraph

Returns:

true, if the execution graph was archived, false otherwise

getArchivedExecutionConfig

public ArchivedExecutionConfig getArchivedExecutionConfig()

Description copied from interface: AccessExecutionGraph

Returns the ArchivedExecutionConfig for this execution graph.

Specified by:

getArchivedExecutionConfig in interface AccessExecutionGraph

Returns:

execution config summary for this execution graph, or null in case of errors

isStoppable

public boolean isStoppable()

Description copied from interface: AccessExecutionGraph

Returns whether the job for this execution graph is stoppable.

Specified by:

isStoppable in interface AccessExecutionGraph

Returns:

true, if all sources tasks are stoppable, false otherwise

getAccumulatorResultsStringified

public StringifiedAccumulatorResult[] getAccumulatorResultsStringified()

Description copied from interface: AccessExecutionGraph

Returns the aggregated user-defined accumulators as strings.

Specified by:

getAccumulatorResultsStringified in interface AccessExecutionGraph

Returns:

aggregated user-defined accumulators as strings.

getAccumulatorsSerialized

public Map<String,SerializedValue<OptionalFailure<Object>>> getAccumulatorsSerialized()

Description copied from interface: AccessExecutionGraph

Returns a map containing the serialized values of user-defined accumulators.

Specified by:

getAccumulatorsSerialized in interface AccessExecutionGraph

Returns:

map containing serialized values of user-defined accumulators

getStateBackendName

public Optional<String> getStateBackendName()

Description copied from interface: AccessExecutionGraph

Returns the state backend name for this ExecutionGraph.

Specified by:

getStateBackendName in interface AccessExecutionGraph

Returns:

The state backend name, or an empty Optional in the case of batch jobs

createFrom

public static ArchivedExecutionGraph createFrom(ExecutionGraph executionGraph)

Create a ArchivedExecutionGraph from the given ExecutionGraph.

Parameters:

executionGraph - to create the ArchivedExecutionGraph from

Returns:

ArchivedExecutionGraph created from the given ExecutionGraph