org.apache.flink.runtime.taskexecutor

Interface JobLeaderListener

public interface JobLeaderListener

Listener for the JobLeaderService. The listener is notified whenever a job manager gained leadership for a registered job and the service could establish a connection to it. Furthermore, the listener is notified when a job manager loses leadership for a job. In case of an error, the handleError(Throwable)} is called.

Method Summary

Modifier and Type	Method and Description
void	handleError(Throwable throwable) Callback for errors which might occur in the JobLeaderService.
void	jobManagerGainedLeadership(JobID jobId, JobMasterGateway jobManagerGateway, JMTMRegistrationSuccess registrationMessage) Callback if a job manager has gained leadership for the job identified by the job id and a connection could be established to this job manager.
void	jobManagerLostLeadership(JobID jobId, JobMasterId jobMasterId) Callback if the job leader for the job with the given job id lost its leadership.
void	jobManagerRejectedRegistration(JobID jobId, String targetAddress, JMTMRegistrationRejection rejection) Callback if a job manager rejected the connection attempts of a task manager.

Method Detail

jobManagerGainedLeadership

void jobManagerGainedLeadership(JobID jobId,
                                JobMasterGateway jobManagerGateway,
                                JMTMRegistrationSuccess registrationMessage)

Callback if a job manager has gained leadership for the job identified by the job id and a connection could be established to this job manager.

Parameters:

jobId - identifying the job for which the job manager has gained leadership

jobManagerGateway - to the job leader

registrationMessage - containing further registration information

jobManagerLostLeadership

void jobManagerLostLeadership(JobID jobId,
                              JobMasterId jobMasterId)

Callback if the job leader for the job with the given job id lost its leadership.

Parameters:

jobId - identifying the job whose leader has lost leadership

jobMasterId - old JobMasterId

handleError

void handleError(Throwable throwable)

Callback for errors which might occur in the JobLeaderService.

Parameters:

throwable - cause

jobManagerRejectedRegistration

void jobManagerRejectedRegistration(JobID jobId,
                                    String targetAddress,
                                    JMTMRegistrationRejection rejection)

Callback if a job manager rejected the connection attempts of a task manager.

Parameters:

jobId - jobId identifying the job to connect to

targetAddress - targetAddress of the responsible job manager

rejection - rejection containing more information about the rejection