public interface JobLeaderListener
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.
|Modifier and Type||Method and Description|
Callback for errors which might occur in the
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.
Callback if the job leader for the job with the given job id lost its leadership.
Callback if a job manager rejected the connection attempts of a task manager.
void jobManagerGainedLeadership(JobID jobId, JobMasterGateway jobManagerGateway, JMTMRegistrationSuccess registrationMessage)
jobId- identifying the job for which the job manager has gained leadership
jobManagerGateway- to the job leader
registrationMessage- containing further registration information
void jobManagerLostLeadership(JobID jobId, JobMasterId jobMasterId)
jobId- identifying the job whose leader has lost leadership
jobMasterId- old JobMasterId
void handleError(Throwable throwable)
void jobManagerRejectedRegistration(JobID jobId, String targetAddress, JMTMRegistrationRejection rejection)
jobId- jobId identifying the job to connect to
targetAddress- targetAddress of the responsible job manager
rejection- rejection containing more information about the rejection
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.