Modifier and Type | Method and Description |
---|---|
AllocationID |
TaskManagerSlot.getAllocationId() |
Modifier and Type | Method and Description |
---|---|
void |
TaskManagerSlot.setAllocationId(AllocationID allocationId) |
Constructor and Description |
---|
TaskManagerSlot(SlotID slotId,
ResourceProfile resourceProfile,
TaskExecutorConnection taskManagerConnection,
AllocationID allocationId) |
Modifier and Type | Method and Description |
---|---|
AllocationID |
TaskDeploymentDescriptor.getAllocationId() |
Constructor and Description |
---|
TaskDeploymentDescriptor(SerializedValue<JobInformation> serializedJobInformation,
SerializedValue<TaskInformation> serializedTaskInformation,
ExecutionAttemptID executionAttemptId,
AllocationID allocationId,
int subtaskIndex,
int attemptNumber,
int targetSlotNumber,
TaskStateHandles taskStateHandles,
Collection<ResultPartitionDeploymentDescriptor> resultPartitionDeploymentDescriptors,
Collection<InputGateDeploymentDescriptor> inputGateDeploymentDescriptors) |
Modifier and Type | Field and Description |
---|---|
protected static AllocationID |
Slot.NO_ALLOCATION_ID |
Modifier and Type | Method and Description |
---|---|
void |
SlotPoolGateway.failAllocation(AllocationID allocationID,
Exception cause) |
void |
SlotPool.failAllocation(AllocationID allocationID,
Exception cause)
Fail the specified allocation and release the corresponding slot if we have one.
|
Modifier and Type | Method and Description |
---|---|
AllocationID |
AllocatedSlot.getSlotAllocationId()
Gets the ID under which the slot is allocated, which uniquely identifies the slot.
|
Constructor and Description |
---|
AllocatedSlot(AllocationID slotAllocationId,
JobID jobID,
TaskManagerLocation location,
int slotNumber,
ResourceProfile resourceProfile,
TaskManagerGateway taskManagerGateway) |
Modifier and Type | Method and Description |
---|---|
void |
JobMasterGateway.failSlot(ResourceID taskManagerId,
AllocationID allocationId,
UUID leaderId,
Exception cause)
Fail the slot with the given allocation id and cause.
|
void |
JobMaster.failSlot(ResourceID taskManagerId,
AllocationID allocationId,
UUID leaderId,
Exception cause) |
Modifier and Type | Method and Description |
---|---|
AllocationID |
SlotRequest.getAllocationId()
Get the unique identification of this request
|
Modifier and Type | Method and Description |
---|---|
void |
ResourceManagerGateway.notifySlotAvailable(UUID resourceManagerLeaderId,
InstanceID instanceId,
SlotID slotID,
AllocationID oldAllocationId)
Sent by the TaskExecutor to notify the ResourceManager that a slot has become available.
|
void |
ResourceManager.notifySlotAvailable(UUID resourceManagerLeaderId,
InstanceID instanceID,
SlotID slotId,
AllocationID allocationId)
Notification from a TaskExecutor that a slot has become available
|
Constructor and Description |
---|
SlotRequest(JobID jobId,
AllocationID allocationId,
ResourceProfile resourceProfile,
String targetAddress) |
Modifier and Type | Method and Description |
---|---|
AllocationID |
PendingSlotRequest.getAllocationId() |
Modifier and Type | Method and Description |
---|---|
void |
SlotManager.freeSlot(SlotID slotId,
AllocationID allocationId)
Free the given slot from the given allocation.
|
void |
ResourceManagerActions.notifyAllocationFailure(JobID jobId,
AllocationID allocationId,
Exception cause) |
boolean |
SlotManager.unregisterSlotRequest(AllocationID allocationId)
Cancels and removes a pending slot request with the given allocation id.
|
Modifier and Type | Method and Description |
---|---|
AllocationID |
SlotStatus.getAllocationID()
Get the allocation id of this slot
|
Modifier and Type | Method and Description |
---|---|
Acknowledge |
TaskExecutor.requestSlot(SlotID slotId,
JobID jobId,
AllocationID allocationId,
String targetAddress,
UUID rmLeaderId)
Requests a slot from the TaskManager
|
Future<Acknowledge> |
TaskExecutorGateway.requestSlot(SlotID slotId,
JobID jobId,
AllocationID allocationId,
String targetAddress,
UUID resourceManagerLeaderId,
Time timeout)
Requests a slot from the TaskManager
|
Constructor and Description |
---|
SlotStatus(SlotID slotID,
ResourceProfile resourceProfile,
JobID jobID,
AllocationID allocationID) |
Modifier and Type | Method and Description |
---|---|
AllocationID |
SlotOccupiedException.getAllocationId() |
Constructor and Description |
---|
SlotOccupiedException(String message,
AllocationID allocationId) |
SlotOccupiedException(String message,
Throwable cause,
AllocationID allocationId) |
SlotOccupiedException(Throwable cause,
AllocationID allocationId) |
Modifier and Type | Method and Description |
---|---|
AllocationID |
TaskSlot.getAllocationId() |
AllocationID |
SlotOffer.getAllocationId() |
AllocationID |
TaskSlotTable.getCurrentAllocation(int index)
Get the current allocation for the task slot with the given index.
|
Modifier and Type | Method and Description |
---|---|
Iterator<AllocationID> |
TaskSlotTable.getActiveSlots(JobID jobId)
Return an iterator of active slots (their application ids) for the given job id.
|
Modifier and Type | Method and Description |
---|---|
boolean |
TaskSlot.allocate(JobID newJobId,
AllocationID newAllocationId)
Allocate the task slot for the given job and allocation id.
|
boolean |
TaskSlotTable.allocateSlot(int index,
JobID jobId,
AllocationID allocationId,
Time slotTimeout)
Allocate the slot with the given index for the given job and allocation id.
|
boolean |
TaskSlotTable.existsActiveSlot(JobID jobId,
AllocationID allocationId)
Check whether there exists an active slot for the given job and allocation id.
|
int |
TaskSlotTable.freeSlot(AllocationID allocationId)
Try to free the slot.
|
void |
SlotActions.freeSlot(AllocationID allocationId)
Free the task slot with the given allocation id.
|
int |
TaskSlotTable.freeSlot(AllocationID allocationId,
Throwable cause)
Tries to free the slot.
|
boolean |
TaskSlot.isActive(JobID activeJobId,
AllocationID activeAllocationId) |
boolean |
TaskSlotTable.isAllocated(int index,
JobID jobId,
AllocationID allocationId)
Check whether the slot for the given index is allocated for the given job and allocation id.
|
boolean |
TaskSlot.isAllocated(JobID jobIdToCheck,
AllocationID allocationIDToCheck) |
boolean |
TaskSlotTable.isValidTimeout(AllocationID allocationId,
UUID ticket)
Check whether the timeout with ticket is valid for the given allocation id.
|
boolean |
TaskSlotTable.markSlotActive(AllocationID allocationId)
Marks the slot under the given allocation id as active.
|
boolean |
TaskSlotTable.markSlotInactive(AllocationID allocationId,
Time slotTimeout)
Marks the slot under the given allocation id as inactive.
|
void |
TaskSlotTable.notifyTimeout(AllocationID key,
UUID ticket) |
void |
SlotActions.timeoutSlot(AllocationID allocationId,
UUID ticket)
Timeout the task slot for the given allocation id.
|
Constructor and Description |
---|
SlotNotActiveException(JobID jobId,
AllocationID allocationId) |
SlotNotFoundException(AllocationID allocationId) |
SlotOffer(AllocationID allocationID,
int index,
ResourceProfile resourceProfile) |
Constructor and Description |
---|
TaskSlotTable(Collection<ResourceProfile> resourceProfiles,
TimerService<AllocationID> timerService) |
Modifier and Type | Method and Description |
---|---|
AllocationID |
Task.getAllocationId() |
Constructor and Description |
---|
Task(JobInformation jobInformation,
TaskInformation taskInformation,
ExecutionAttemptID executionAttemptID,
AllocationID slotAllocationId,
int subtaskIndex,
int attemptNumber,
Collection<ResultPartitionDeploymentDescriptor> resultPartitionDeploymentDescriptors,
Collection<InputGateDeploymentDescriptor> inputGateDeploymentDescriptors,
int targetSlotNumber,
TaskStateHandles taskStateHandles,
MemoryManager memManager,
IOManager ioManager,
NetworkEnvironment networkEnvironment,
BroadcastVariableManager bcVarManager,
TaskManagerActions taskManagerActions,
InputSplitProvider inputSplitProvider,
CheckpointResponder checkpointResponder,
LibraryCacheManager libraryCache,
FileCache fileCache,
TaskManagerRuntimeInfo taskManagerConfig,
TaskMetricGroup metricGroup,
ResultPartitionConsumableNotifier resultPartitionConsumableNotifier,
PartitionProducerStateChecker partitionProducerStateChecker,
Executor executor)
IMPORTANT: This constructor may not start any work that would need to
be undone in the case of a failing task deployment.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.