org.apache.flink.runtime.dispatcher.runner

Class SessionDispatcherLeaderProcess

java.lang.Object

org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess

All Implemented Interfaces:

JobGraphStore.JobGraphListener

public class SessionDispatcherLeaderProcess
extends Object
implements JobGraphStore.JobGraphListener

Process which encapsulates the job recovery logic and life cycle management of a Dispatcher.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	AbstractDispatcherLeaderProcess.State The state of the DispatcherLeaderProcess.

Field Summary

Fields

Modifier and Type	Field and Description
protected org.slf4j.Logger	log

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Void>	closeAsync() Trigger the closing of the resource and return the corresponding close future.
static SessionDispatcherLeaderProcess	create(UUID leaderSessionId, org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess.DispatcherGatewayServiceFactory dispatcherFactory, JobGraphStore jobGraphStore, Executor ioExecutor, FatalErrorHandler fatalErrorHandler)
CompletableFuture<DispatcherGateway>	getDispatcherGateway()
protected Optional<org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess.DispatcherGatewayService>	getDispatcherService()
CompletableFuture<String>	getLeaderAddressFuture()
UUID	getLeaderSessionId()
CompletableFuture<ApplicationStatus>	getShutDownFuture()
void	onAddedJobGraph(JobID jobId) Callback for JobGraph instances added by a different JobGraphStore instance.
protected CompletableFuture<Void>	onClose()
void	onRemovedJobGraph(JobID jobId) Callback for JobGraph instances removed by a different JobGraphStore instance.
protected void	onStart()
void	start()

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

Field Detail

log

protected final org.slf4j.Logger log

Method Detail

onStart

protected void onStart()

onClose

protected CompletableFuture<Void> onClose()

onAddedJobGraph

public void onAddedJobGraph(JobID jobId)

Description copied from interface: JobGraphStore.JobGraphListener

Callback for JobGraph instances added by a different JobGraphStore instance.

Important: It is possible to get false positives and be notified about a job graph, which was added by this instance.

Specified by:

onAddedJobGraph in interface JobGraphStore.JobGraphListener

Parameters:

jobId - The JobID of the added job graph

onRemovedJobGraph

public void onRemovedJobGraph(JobID jobId)

Description copied from interface: JobGraphStore.JobGraphListener

Callback for JobGraph instances removed by a different JobGraphStore instance.

Specified by:

onRemovedJobGraph in interface JobGraphStore.JobGraphListener

Parameters:

jobId - The JobID of the removed job graph

create

public static SessionDispatcherLeaderProcess create(UUID leaderSessionId,
                                                    org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess.DispatcherGatewayServiceFactory dispatcherFactory,
                                                    JobGraphStore jobGraphStore,
                                                    Executor ioExecutor,
                                                    FatalErrorHandler fatalErrorHandler)

start

public final void start()

getLeaderSessionId

public final UUID getLeaderSessionId()

getDispatcherGateway

public final CompletableFuture<DispatcherGateway> getDispatcherGateway()

getLeaderAddressFuture

public final CompletableFuture<String> getLeaderAddressFuture()

getShutDownFuture

public CompletableFuture<ApplicationStatus> getShutDownFuture()

getDispatcherService

protected final Optional<org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess.DispatcherGatewayService> getDispatcherService()

closeAsync

public final CompletableFuture<Void> closeAsync()

Description copied from interface: AutoCloseableAsync

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

Returns:

Future which is completed once the resource has been closed