Uses of Class
org.apache.flink.runtime.jobmaster.JobMasterId

Packages that use JobMasterId

Package	Description
org.apache.flink.runtime.jobmaster
org.apache.flink.runtime.jobmaster.slotpool
org.apache.flink.runtime.resourcemanager
org.apache.flink.runtime.resourcemanager.registration
org.apache.flink.runtime.taskexecutor

Uses of JobMasterId in org.apache.flink.runtime.jobmaster

Methods in org.apache.flink.runtime.jobmaster that return JobMasterId

Modifier and Type	Method and Description
static JobMasterId	JobMasterId.fromUuidOrNull(UUID uuid) If the given uuid is null, this returns null, otherwise a JobMasterId that corresponds to the UUID, via JobMasterId(UUID).
static JobMasterId	JobMasterId.generate() Generates a new random JobMasterId.

Methods in org.apache.flink.runtime.jobmaster with parameters of type JobMasterId

Modifier and Type	Method and Description
CompletableFuture<Acknowledge>	JobMaster.start(JobMasterId newJobMasterId) Start the rpc service and begin to run the job.
CompletableFuture<Acknowledge>	JobMasterService.start(JobMasterId jobMasterId) Start the JobMaster service with the given JobMasterId.

Constructors in org.apache.flink.runtime.jobmaster with parameters of type JobMasterId

Constructor and Description
RpcTaskManagerGateway(TaskExecutorGateway taskExecutorGateway, JobMasterId jobMasterId)

Uses of JobMasterId in org.apache.flink.runtime.jobmaster.slotpool

Methods in org.apache.flink.runtime.jobmaster.slotpool with parameters of type JobMasterId

Modifier and Type	Method and Description
void	SlotPool.start(JobMasterId jobMasterId, String newJobManagerAddress, ComponentMainThreadExecutor jmMainThreadScheduledExecutor)
void	SlotPoolImpl.start(JobMasterId jobMasterId, String newJobManagerAddress, ComponentMainThreadExecutor componentMainThreadExecutor) Start the slot pool to accept RPC calls.

Uses of JobMasterId in org.apache.flink.runtime.resourcemanager

Methods in org.apache.flink.runtime.resourcemanager that return types with arguments of type JobMasterId

Modifier and Type	Method and Description
CompletableFuture<JobMasterId>	JobLeaderIdService.getLeaderId(JobID jobId)

Methods in org.apache.flink.runtime.resourcemanager with parameters of type JobMasterId

Modifier and Type	Method and Description
void	JobLeaderIdActions.jobLeaderLostLeadership(JobID jobId, JobMasterId oldJobMasterId) Callback when a monitored job leader lost its leadership.
protected void	ResourceManager.jobLeaderLostLeadership(JobID jobId, JobMasterId oldJobMasterId)
CompletableFuture<RegistrationResponse>	ResourceManagerGateway.registerJobManager(JobMasterId jobMasterId, ResourceID jobMasterResourceId, String jobMasterAddress, JobID jobId, Time timeout) Register a JobMaster at the resource manager.
CompletableFuture<RegistrationResponse>	ResourceManager.registerJobManager(JobMasterId jobMasterId, ResourceID jobManagerResourceId, String jobManagerAddress, JobID jobId, Time timeout)
CompletableFuture<Acknowledge>	ResourceManagerGateway.requestSlot(JobMasterId jobMasterId, SlotRequest slotRequest, Time timeout) Requests a slot from the resource manager.
CompletableFuture<Acknowledge>	ResourceManager.requestSlot(JobMasterId jobMasterId, SlotRequest slotRequest, Time timeout)

Uses of JobMasterId in org.apache.flink.runtime.resourcemanager.registration

Methods in org.apache.flink.runtime.resourcemanager.registration that return JobMasterId

Modifier and Type	Method and Description
JobMasterId	JobManagerRegistration.getJobMasterId()

Uses of JobMasterId in org.apache.flink.runtime.taskexecutor

Methods in org.apache.flink.runtime.taskexecutor that return JobMasterId

Modifier and Type	Method and Description
JobMasterId	JobTable.Connection.getJobMasterId()

Methods in org.apache.flink.runtime.taskexecutor with parameters of type JobMasterId

Modifier and Type	Method and Description
void	JobLeaderListener.jobManagerLostLeadership(JobID jobId, JobMasterId jobMasterId) Callback if the job leader for the job with the given job id lost its leadership.
CompletableFuture<Acknowledge>	TaskExecutor.submitTask(TaskDeploymentDescriptor tdd, JobMasterId jobMasterId, Time timeout)
CompletableFuture<Acknowledge>	TaskExecutorGateway.submitTask(TaskDeploymentDescriptor tdd, JobMasterId jobMasterId, Time timeout) Submit a Task to the TaskExecutor.