org.apache.flink.runtime.dispatcher.cleanup

Class CheckpointResourcesCleanupRunner

java.lang.Object

org.apache.flink.runtime.dispatcher.cleanup.CheckpointResourcesCleanupRunner

All Implemented Interfaces:

AutoCloseable, JobManagerRunner, AutoCloseableAsync

public class CheckpointResourcesCleanupRunner
extends Object
implements JobManagerRunner

CheckpointResourcesCleanupRunner implements JobManagerRunner in a way, that only the checkpoint-related resources are instantiated. It triggers any job-specific cleanup that's usually performed by the JobMaster without rebuilding the corresponding ExecutionGraph.

Constructor Summary

Constructors

Constructor and Description
CheckpointResourcesCleanupRunner(JobResult jobResult, CheckpointRecoveryFactory checkpointRecoveryFactory, SharedStateRegistryFactory sharedStateRegistryFactory, Configuration jobManagerConfiguration, Executor cleanupExecutor, long initializationTimestamp)

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Acknowledge>	cancel(Time timeout) Cancels the currently executed job.
CompletableFuture<Void>	closeAsync() Trigger the closing of the resource and return the corresponding close future.
JobID	getJobID() Get the job id of the executed job.
CompletableFuture<JobMasterGateway>	getJobMasterGateway() Get the JobMasterGateway of the JobMaster.
CompletableFuture<JobManagerRunnerResult>	getResultFuture() Get the result future of this runner.
boolean	isInitialized() Flag indicating if the JobManagerRunner has been initialized.
CompletableFuture<ExecutionGraphInfo>	requestJob(Time timeout) Requests the ExecutionGraphInfo of the executed job.
CompletableFuture<JobDetails>	requestJobDetails(Time timeout) Request the details of the executed job.
CompletableFuture<JobStatus>	requestJobStatus(Time timeout) Requests the current job status.
void	start() Start the execution of the JobMaster.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.util.AutoCloseableAsync

close

Constructor Detail

CheckpointResourcesCleanupRunner

public CheckpointResourcesCleanupRunner(JobResult jobResult,
                                        CheckpointRecoveryFactory checkpointRecoveryFactory,
                                        SharedStateRegistryFactory sharedStateRegistryFactory,
                                        Configuration jobManagerConfiguration,
                                        Executor cleanupExecutor,
                                        long initializationTimestamp)

Method Detail

closeAsync

public CompletableFuture<Void> closeAsync()

Description copied from interface: AutoCloseableAsync

Trigger the closing of the resource and return the corresponding close future.

Specified by:

closeAsync in interface AutoCloseableAsync

Returns:

Future which is completed once the resource has been closed

start

public void start()
           throws Exception

Description copied from interface: JobManagerRunner

Start the execution of the JobMaster.

Specified by:

start in interface JobManagerRunner

Throws:

Exception - if the JobMaster cannot be started

getJobMasterGateway

public CompletableFuture<JobMasterGateway> getJobMasterGateway()

Description copied from interface: JobManagerRunner

Get the JobMasterGateway of the JobMaster. The future is only completed if the JobMaster becomes leader.

Specified by:

getJobMasterGateway in interface JobManagerRunner

Returns:

Future with the JobMasterGateway once the underlying JobMaster becomes leader

getResultFuture

public CompletableFuture<JobManagerRunnerResult> getResultFuture()

Description copied from interface: JobManagerRunner

Get the result future of this runner. The future is completed once the executed job reaches a globally terminal state or if the initialization of the JobMaster fails. If the result future is completed exceptionally via JobNotFinishedException, then this signals that the job has not been completed successfully. All other exceptional completions denote an unexpected exception which leads to a process restart.

Specified by:

getResultFuture in interface JobManagerRunner

Returns:

Future which is completed with the job result

getJobID

public JobID getJobID()

Description copied from interface: JobManagerRunner

Get the job id of the executed job.

Specified by:

getJobID in interface JobManagerRunner

Returns:

job id of the executed job

cancel

public CompletableFuture<Acknowledge> cancel(Time timeout)

Description copied from interface: JobManagerRunner

Cancels the currently executed job.

Specified by:

cancel in interface JobManagerRunner

Parameters:

timeout - of this operation

Returns:

Future acknowledge of the operation

requestJobStatus

public CompletableFuture<JobStatus> requestJobStatus(Time timeout)

Description copied from interface: JobManagerRunner

Requests the current job status.

Specified by:

requestJobStatus in interface JobManagerRunner

Parameters:

timeout - for the rpc call

Returns:

Future containing the current job status

requestJobDetails

public CompletableFuture<JobDetails> requestJobDetails(Time timeout)

Description copied from interface: JobManagerRunner

Request the details of the executed job.

Specified by:

requestJobDetails in interface JobManagerRunner

Parameters:

timeout - for the rpc call

Returns:

Future details of the executed job

requestJob

public CompletableFuture<ExecutionGraphInfo> requestJob(Time timeout)

Description copied from interface: JobManagerRunner

Requests the ExecutionGraphInfo of the executed job.

Specified by:

requestJob in interface JobManagerRunner

Parameters:

timeout - for the rpc call

Returns:

Future which is completed with the ExecutionGraphInfo of the executed job

isInitialized

public boolean isInitialized()

Description copied from interface: JobManagerRunner

Flag indicating if the JobManagerRunner has been initialized.

Specified by:

isInitialized in interface JobManagerRunner

Returns:

true if the JobManagerRunner has been initialized.