Modifier and Type | Method and Description |
---|---|
void |
ResourceManager.notifySlotAvailable(InstanceID instanceID,
SlotID slotId,
AllocationID allocationId) |
void |
ResourceManagerGateway.notifySlotAvailable(InstanceID instanceId,
SlotID slotID,
AllocationID oldAllocationId)
Sent by the TaskExecutor to notify the ResourceManager that a slot has become available.
|
protected void |
ResourceManager.releaseResource(InstanceID instanceId,
Exception cause) |
CompletableFuture<Acknowledge> |
ResourceManager.sendSlotReport(ResourceID taskManagerResourceId,
InstanceID taskManagerRegistrationId,
SlotReport slotReport,
Time timeout) |
CompletableFuture<Acknowledge> |
ResourceManagerGateway.sendSlotReport(ResourceID taskManagerResourceId,
InstanceID taskManagerRegistrationId,
SlotReport slotReport,
Time timeout)
Sends the given
SlotReport to the ResourceManager. |
Modifier and Type | Method and Description |
---|---|
InstanceID |
TaskExecutorConnection.getInstanceID() |
Modifier and Type | Method and Description |
---|---|
InstanceID |
TaskManagerSlotInformation.getInstanceId() |
InstanceID |
FineGrainedTaskManagerSlot.getInstanceId() |
InstanceID |
FineGrainedTaskManagerRegistration.getInstanceId() |
InstanceID |
TaskManagerInfo.getInstanceId()
Get the instanceId of this task manager.
|
InstanceID |
TaskManagerRegistration.getInstanceId() |
Modifier and Type | Method and Description |
---|---|
Map<JobID,Map<InstanceID,ResourceCounter>> |
ResourceAllocationResult.getAllocationsOnRegisteredResources() |
Modifier and Type | Method and Description |
---|---|
ResourceAllocationResult.Builder |
ResourceAllocationResult.Builder.addAllocationOnRegisteredResource(JobID jobId,
InstanceID instanceId,
ResourceProfile resourceProfile) |
CompletableFuture<Void> |
SlotStatusSyncer.allocateSlot(InstanceID instanceId,
JobID jobId,
String targetAddress,
ResourceProfile resourceProfile)
Allocate a slot from the task manager.
|
CompletableFuture<Void> |
DefaultSlotStatusSyncer.allocateSlot(InstanceID instanceId,
JobID jobId,
String targetAddress,
ResourceProfile resourceProfile) |
Collection<SlotInfo> |
SlotManager.getAllocatedSlotsOf(InstanceID instanceID) |
Collection<SlotInfo> |
DeclarativeSlotManager.getAllocatedSlotsOf(InstanceID instanceID) |
Collection<SlotInfo> |
FineGrainedSlotManager.getAllocatedSlotsOf(InstanceID instanceID) |
ResourceProfile |
SlotManager.getFreeResourceOf(InstanceID instanceID) |
ResourceProfile |
DeclarativeSlotManager.getFreeResourceOf(InstanceID instanceID) |
ResourceProfile |
FineGrainedTaskManagerTracker.getFreeResourceOf(InstanceID instanceId) |
ResourceProfile |
FineGrainedSlotManager.getFreeResourceOf(InstanceID instanceID) |
ResourceProfile |
ClusterResourceStatisticsProvider.getFreeResourceOf(InstanceID instanceId)
Get profile of free resources from the TaskManager with the given instance id.
|
int |
SlotManager.getNumberFreeSlotsOf(InstanceID instanceId) |
int |
DeclarativeSlotManager.getNumberFreeSlotsOf(InstanceID instanceId) |
int |
FineGrainedTaskManagerTracker.getNumberFreeSlotsOf(InstanceID instanceId) |
int |
FineGrainedSlotManager.getNumberFreeSlotsOf(InstanceID instanceId) |
int |
ClusterResourceStatisticsProvider.getNumberFreeSlotsOf(InstanceID instanceId)
Get number of free slots from the TaskManager with the given instance id.
|
int |
SlotManager.getNumberRegisteredSlotsOf(InstanceID instanceId) |
int |
DeclarativeSlotManager.getNumberRegisteredSlotsOf(InstanceID instanceId) |
int |
FineGrainedTaskManagerTracker.getNumberRegisteredSlotsOf(InstanceID instanceId) |
int |
FineGrainedSlotManager.getNumberRegisteredSlotsOf(InstanceID instanceId) |
int |
ClusterResourceStatisticsProvider.getNumberRegisteredSlotsOf(InstanceID instanceId)
Get number of registered slots from the TaskManager with the given instance id.
|
ResourceProfile |
SlotManager.getRegisteredResourceOf(InstanceID instanceID) |
ResourceProfile |
DeclarativeSlotManager.getRegisteredResourceOf(InstanceID instanceID) |
ResourceProfile |
FineGrainedTaskManagerTracker.getRegisteredResourceOf(InstanceID instanceId) |
ResourceProfile |
FineGrainedSlotManager.getRegisteredResourceOf(InstanceID instanceID) |
ResourceProfile |
ClusterResourceStatisticsProvider.getRegisteredResourceOf(InstanceID instanceId)
Get profile of registered resources from the TaskManager with the given instance id.
|
Optional<TaskManagerInfo> |
FineGrainedTaskManagerTracker.getRegisteredTaskManager(InstanceID instanceId) |
long |
FineGrainedSlotManager.getTaskManagerIdleSince(InstanceID instanceId) |
void |
FineGrainedTaskManagerTracker.notifySlotStatus(AllocationID allocationId,
JobID jobId,
InstanceID instanceId,
ResourceProfile resourceProfile,
org.apache.flink.runtime.resourcemanager.slotmanager.SlotState slotState) |
void |
ResourceActions.releaseResource(InstanceID instanceId,
Exception cause)
Releases the resource with the given instance id.
|
void |
FineGrainedTaskManagerTracker.removeTaskManager(InstanceID instanceId) |
boolean |
SlotManager.reportSlotStatus(InstanceID instanceId,
SlotReport slotReport)
Reports the current slot allocations for a task manager identified by the given instance id.
|
boolean |
DeclarativeSlotManager.reportSlotStatus(InstanceID instanceId,
SlotReport slotReport)
Reports the current slot allocations for a task manager identified by the given instance id.
|
boolean |
SlotStatusSyncer.reportSlotStatus(InstanceID instanceId,
SlotReport slotReport)
Reconcile the slot status with the slot report.
|
boolean |
DefaultSlotStatusSyncer.reportSlotStatus(InstanceID instanceId,
SlotReport slotReport) |
boolean |
FineGrainedSlotManager.reportSlotStatus(InstanceID instanceId,
SlotReport slotReport)
Reports the current slot allocations for a task manager identified by the given instance id.
|
boolean |
SlotManager.unregisterTaskManager(InstanceID instanceId,
Exception cause)
Unregisters the task manager identified by the given instance id and its associated slots
from the slot manager.
|
boolean |
DeclarativeSlotManager.unregisterTaskManager(InstanceID instanceId,
Exception cause) |
boolean |
FineGrainedSlotManager.unregisterTaskManager(InstanceID instanceId,
Exception cause) |
Modifier and Type | Method and Description |
---|---|
<T extends TaskManagerSlotInformation> |
AnyMatchingSlotMatchingStrategy.findMatchingSlot(ResourceProfile requestedProfile,
Collection<T> freeSlots,
java.util.function.Function<InstanceID,Integer> numberRegisteredSlotsLookup) |
<T extends TaskManagerSlotInformation> |
SlotMatchingStrategy.findMatchingSlot(ResourceProfile requestedProfile,
Collection<T> freeSlots,
java.util.function.Function<InstanceID,Integer> numberRegisteredSlotsLookup)
Finds a matching slot for the requested
ResourceProfile given the collection of free
slots and the total number of slots per TaskExecutor. |
<T extends TaskManagerSlotInformation> |
LeastUtilizationSlotMatchingStrategy.findMatchingSlot(ResourceProfile requestedProfile,
Collection<T> freeSlots,
java.util.function.Function<InstanceID,Integer> numberRegisteredSlotsLookup) |
Modifier and Type | Method and Description |
---|---|
InstanceID |
TaskExecutorRegistrationSuccess.getRegistrationId()
Gets the ID that the ResourceManager assigned the registration.
|
Constructor and Description |
---|
TaskExecutorRegistrationSuccess(InstanceID registrationId,
ResourceID resourceManagerResourceId,
ClusterInformation clusterInformation)
Create a new
TaskExecutorRegistrationSuccess message. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.