org.apache.flink.runtime.scheduler.adaptivebatch

Class DefaultBatchJobRecoveryHandler

java.lang.Object

org.apache.flink.runtime.scheduler.adaptivebatch.DefaultBatchJobRecoveryHandler

All Implemented Interfaces:

JobEventReplayHandler, BatchJobRecoveryHandler

public class DefaultBatchJobRecoveryHandler
extends Object
implements BatchJobRecoveryHandler, JobEventReplayHandler

Default implementation of BatchJobRecoveryHandler and JobEventReplayHandler.

Constructor Summary

Constructors

Constructor and Description
DefaultBatchJobRecoveryHandler(JobEventManager jobEventManager, Configuration jobMasterConfiguration)

Method Summary

Modifier and Type	Method and Description
void	finalizeReplay() Called when finalizing replaying job event.
void	initialize(BatchJobRecoveryContext context) Initializes the recovery handler with the batch job recovery context.
boolean	isRecovering() Determines whether the job is recovering.
boolean	needRecover() Determines whether the job needs to undergo recovery.
void	onExecutionFinished(ExecutionVertexID executionVertexId) Records the execution vertex finished event for use during future batch job recovery.
void	onExecutionJobVertexInitialization(JobVertexID jobVertexId, int parallelism, Map<IntermediateDataSetID,JobVertexInputInfo> jobVertexInputInfos) Records the job vertex initialization event for use during future batch job recovery.
void	onExecutionVertexReset(Collection<ExecutionVertexID> vertices) Handles the reset event for a collection of execution vertices and records the event for use during future batch job recovery.
void	replayOneEvent(JobEvent jobEvent) Called to replay one job event.
void	startRecovering() Starts the recovery process.
void	startReplay() Called when starting replaying job event.
void	stop(boolean cleanUp) Stops the job recovery handler and optionally clean up.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultBatchJobRecoveryHandler

public DefaultBatchJobRecoveryHandler(JobEventManager jobEventManager,
                                      Configuration jobMasterConfiguration)

Method Detail

initialize

public void initialize(BatchJobRecoveryContext context)

Description copied from interface: BatchJobRecoveryHandler

Initializes the recovery handler with the batch job recovery context.

Specified by:

initialize in interface BatchJobRecoveryHandler

stop

public void stop(boolean cleanUp)

Description copied from interface: BatchJobRecoveryHandler

Stops the job recovery handler and optionally clean up.

Specified by:

stop in interface BatchJobRecoveryHandler

Parameters:

cleanUp - whether to clean up.

startRecovering

public void startRecovering()

Description copied from interface: BatchJobRecoveryHandler

Starts the recovery process.

Specified by:

startRecovering in interface BatchJobRecoveryHandler

needRecover

public boolean needRecover()

Description copied from interface: BatchJobRecoveryHandler

Determines whether the job needs to undergo recovery.

Specified by:

needRecover in interface BatchJobRecoveryHandler

isRecovering

public boolean isRecovering()

Description copied from interface: BatchJobRecoveryHandler

Determines whether the job is recovering.

Specified by:

isRecovering in interface BatchJobRecoveryHandler

startReplay

public void startReplay()

Description copied from interface: JobEventReplayHandler

Called when starting replaying job event.

Specified by:

startReplay in interface JobEventReplayHandler

replayOneEvent

public void replayOneEvent(JobEvent jobEvent)

Description copied from interface: JobEventReplayHandler

Called to replay one job event.

Specified by:

replayOneEvent in interface JobEventReplayHandler

finalizeReplay

public void finalizeReplay()
                    throws Exception

Description copied from interface: JobEventReplayHandler

Called when finalizing replaying job event.

Specified by:

finalizeReplay in interface JobEventReplayHandler

Throws:

Exception

onExecutionVertexReset

public void onExecutionVertexReset(Collection<ExecutionVertexID> vertices)

Description copied from interface: BatchJobRecoveryHandler

Handles the reset event for a collection of execution vertices and records the event for use during future batch job recovery.

Specified by:

onExecutionVertexReset in interface BatchJobRecoveryHandler

Parameters:

vertices - a collection of execution vertex IDs that have been reset.

onExecutionJobVertexInitialization

public void onExecutionJobVertexInitialization(JobVertexID jobVertexId,
                                               int parallelism,
                                               Map<IntermediateDataSetID,JobVertexInputInfo> jobVertexInputInfos)

Description copied from interface: BatchJobRecoveryHandler

Records the job vertex initialization event for use during future batch job recovery.

Specified by:

onExecutionJobVertexInitialization in interface BatchJobRecoveryHandler

Parameters:

jobVertexId - the id of the job vertex being initialized.

parallelism - the parallelism of the job vertex.

jobVertexInputInfos - a map of intermediate dataset IDs to job vertex input info.

onExecutionFinished

public void onExecutionFinished(ExecutionVertexID executionVertexId)

Description copied from interface: BatchJobRecoveryHandler

Records the execution vertex finished event for use during future batch job recovery.

Specified by:

onExecutionFinished in interface BatchJobRecoveryHandler

Parameters:

executionVertexId - the id of the execution vertex is finished.