Package | Description |
---|---|
org.apache.flink.runtime.jobmaster | |
org.apache.flink.runtime.registration | |
org.apache.flink.runtime.resourcemanager | |
org.apache.flink.runtime.taskexecutor |
Modifier and Type | Class and Description |
---|---|
class |
JMTMRegistrationSuccess
Message indicating a successful
JobMaster and TaskExecutor registration. |
class |
JobMasterRegistrationSuccess
Base class for responses from the ResourceManager to a registration attempt by a JobMaster.
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<RegistrationResponse> |
JobMaster.registerTaskManager(String taskManagerRpcAddress,
TaskManagerLocation taskManagerLocation,
Time timeout) |
CompletableFuture<RegistrationResponse> |
JobMasterGateway.registerTaskManager(String taskManagerRpcAddress,
TaskManagerLocation taskManagerLocation,
Time timeout)
Registers the task manager at the job manager.
|
Modifier and Type | Class and Description |
---|---|
static class |
RegistrationResponse.Decline
A rejected (declined) registration.
|
static class |
RegistrationResponse.Success
Base class for a successful registration.
|
Modifier and Type | Method and Description |
---|---|
protected abstract CompletableFuture<RegistrationResponse> |
RetryingRegistration.invokeRegistration(G gateway,
F fencingToken,
long timeoutMillis) |
Modifier and Type | Method and Description |
---|---|
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<RegistrationResponse> |
ResourceManagerGateway.registerTaskExecutor(TaskExecutorRegistration taskExecutorRegistration,
Time timeout)
Register a
TaskExecutor at the resource manager. |
CompletableFuture<RegistrationResponse> |
ResourceManager.registerTaskExecutor(TaskExecutorRegistration taskExecutorRegistration,
Time timeout) |
Modifier and Type | Class and Description |
---|---|
class |
TaskExecutorRegistrationSuccess
Base class for responses from the ResourceManager to a registration attempt by a
TaskExecutor.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.