org.apache.flink.runtime.jobmaster

Class JobManagerRunner

java.lang.Object

org.apache.flink.runtime.jobmaster.JobManagerRunner

All Implemented Interfaces:

OnCompletionActions, LeaderContender, FatalErrorHandler

public class JobManagerRunner
extends Object
implements LeaderContender, OnCompletionActions, FatalErrorHandler

The runner for the job manager. It deals with job level leader election and make underlying job manager properly reacted.

Constructor Summary

Constructors

Constructor and Description

JobManagerRunner(ResourceID resourceId, JobGraph jobGraph, Configuration configuration, RpcService rpcService, HighAvailabilityServices haServices, HeartbeatServices heartbeatServices, JobManagerServices jobManagerServices, MetricRegistry metricRegistry, OnCompletionActions toNotifyOnComplete, FatalErrorHandler errorHandler) Exceptions that occur while creating the JobManager or JobManagerRunner are directly thrown and not reported to the given FatalErrorHandler.

Method Summary

Modifier and Type	Method and Description
String	getAddress() Returns the address of the LeaderContender under which other instances can connect to it.
JobMasterGateway	getJobManagerGateway()
void	grantLeadership(UUID leaderSessionID) Callback method which is called by the LeaderElectionService upon selecting this instance as the new leader.
void	handleError(Exception exception) Callback method which is called by LeaderElectionService in case of an error in the service thread.
void	jobFailed(Throwable cause) Job completion notification triggered by JobManager.
void	jobFinished(JobExecutionResult result) Job completion notification triggered by JobManager.
void	jobFinishedByOther() Job completion notification triggered by self.
void	onFatalError(Throwable exception) Job completion notification triggered by JobManager or self.
void	revokeLeadership() Callback method which is called by the LeaderElectionService upon revoking the leadership of a former leader.
void	shutdown()
void	start()

Methods inherited from class java.lang.Object

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

Constructor Detail

JobManagerRunner

public JobManagerRunner(ResourceID resourceId,
                        JobGraph jobGraph,
                        Configuration configuration,
                        RpcService rpcService,
                        HighAvailabilityServices haServices,
                        HeartbeatServices heartbeatServices,
                        JobManagerServices jobManagerServices,
                        MetricRegistry metricRegistry,
                        OnCompletionActions toNotifyOnComplete,
                        FatalErrorHandler errorHandler)
                 throws Exception

Exceptions that occur while creating the JobManager or JobManagerRunner are directly thrown and not reported to the given FatalErrorHandler.

This JobManagerRunner assumes that it owns the given JobManagerServices. It will shut them down on error and on calls to shutdown().

Throws:

Exception - Thrown if the runner cannot be set up, because either one of the required services could not be started, ot the Job could not be initialized.

Method Detail

getJobManagerGateway

public JobMasterGateway getJobManagerGateway()

start

public void start()
           throws Exception

Throws:

Exception

shutdown

public void shutdown()
              throws Exception

Throws:

Exception

jobFinished

public void jobFinished(JobExecutionResult result)

Job completion notification triggered by JobManager.

Specified by:

jobFinished in interface OnCompletionActions

jobFailed

public void jobFailed(Throwable cause)

Job completion notification triggered by JobManager.

Specified by:

jobFailed in interface OnCompletionActions

jobFinishedByOther

public void jobFinishedByOther()

Job completion notification triggered by self.

Specified by:

jobFinishedByOther in interface OnCompletionActions

onFatalError

public void onFatalError(Throwable exception)

Job completion notification triggered by JobManager or self.

Specified by:

onFatalError in interface FatalErrorHandler

Parameters:

exception - cause

grantLeadership

public void grantLeadership(UUID leaderSessionID)

Description copied from interface: LeaderContender

Callback method which is called by the LeaderElectionService upon selecting this instance as the new leader. The method is called with the new leader session ID.

Specified by:

grantLeadership in interface LeaderContender

Parameters:

leaderSessionID - New leader session ID

revokeLeadership

public void revokeLeadership()

Description copied from interface: LeaderContender

Callback method which is called by the LeaderElectionService upon revoking the leadership of a former leader. This might happen in case that multiple contenders have been granted leadership.

Specified by:

revokeLeadership in interface LeaderContender

getAddress

public String getAddress()

Description copied from interface: LeaderContender

Returns the address of the LeaderContender under which other instances can connect to it.

Specified by:

getAddress in interface LeaderContender

Returns:

Address of this contender.

handleError

public void handleError(Exception exception)

Description copied from interface: LeaderContender

Callback method which is called by LeaderElectionService in case of an error in the service thread.

Specified by:

handleError in interface LeaderContender

Parameters:

exception - Caught exception