org.apache.flink.runtime.taskexecutor

Class DefaultJobLeaderService

java.lang.Object

org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService

All Implemented Interfaces:

JobLeaderService

public class DefaultJobLeaderService
extends Object
implements JobLeaderService

Default implementation of JobLeaderService.

Constructor Summary

Constructors

Constructor and Description
DefaultJobLeaderService(UnresolvedTaskManagerLocation location, RetryingRegistrationConfiguration retryingRegistrationConfiguration)

Method Summary

Modifier and Type	Method and Description
void	addJob(JobID jobId, String defaultTargetAddress) Add the given job to be monitored.
boolean	containsJob(JobID jobId) Check whether the service monitors the given job.
void	reconnect(JobID jobId) Triggers reconnection to the last known leader of the given job.
void	removeJob(JobID jobId) Remove the given job from being monitored by the job leader service.
void	start(String initialOwnerAddress, RpcService initialRpcService, HighAvailabilityServices initialHighAvailabilityServices, JobLeaderListener initialJobLeaderListener) Start the job leader service with the given services.
void	stop() Stop the job leader services.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultJobLeaderService

public DefaultJobLeaderService(UnresolvedTaskManagerLocation location,
                               RetryingRegistrationConfiguration retryingRegistrationConfiguration)

Method Detail

start

public void start(String initialOwnerAddress,
                  RpcService initialRpcService,
                  HighAvailabilityServices initialHighAvailabilityServices,
                  JobLeaderListener initialJobLeaderListener)

Description copied from interface: JobLeaderService

Start the job leader service with the given services.

Specified by:

start in interface JobLeaderService

Parameters:

initialOwnerAddress - to be used for establishing connections (source address)

initialRpcService - to be used to create rpc connections

initialHighAvailabilityServices - to create leader retrieval services for the different jobs

initialJobLeaderListener - listening for job leader changes

stop

public void stop()
          throws Exception

Description copied from interface: JobLeaderService

Stop the job leader services. This implies stopping all leader retrieval services for the different jobs and their leader retrieval listeners.

Specified by:

stop in interface JobLeaderService

Throws:

Exception - if an error occurs while stopping the service

removeJob

public void removeJob(JobID jobId)

Description copied from interface: JobLeaderService

Remove the given job from being monitored by the job leader service.

Specified by:

removeJob in interface JobLeaderService

Parameters:

jobId - identifying the job to remove from monitoring

addJob

public void addJob(JobID jobId,
                   String defaultTargetAddress)
            throws Exception

Description copied from interface: JobLeaderService

Add the given job to be monitored. This means that the service tries to detect leaders for this job and then tries to establish a connection to it.

Specified by:

addJob in interface JobLeaderService

Parameters:

jobId - identifying the job to monitor

defaultTargetAddress - of the job leader

Throws:

Exception - if an error occurs while starting the leader retrieval service

reconnect

public void reconnect(JobID jobId)

Description copied from interface: JobLeaderService

Triggers reconnection to the last known leader of the given job.

Specified by:

reconnect in interface JobLeaderService

Parameters:

jobId - specifying the job for which to trigger reconnection

containsJob

@VisibleForTesting
public boolean containsJob(JobID jobId)

Check whether the service monitors the given job.

Specified by:

containsJob in interface JobLeaderService

Parameters:

jobId - identifying the job

Returns:

True if the given job is monitored; otherwise false