Package | Description |
---|---|
org.apache.flink.runtime.instance | |
org.apache.flink.runtime.jobmaster | |
org.apache.flink.runtime.resourcemanager | |
org.apache.flink.runtime.taskexecutor |
Modifier and Type | Method and Description |
---|---|
Future<SimpleSlot> |
SlotPool.allocateSlot(ScheduledUnit task,
ResourceProfile resources,
Iterable<TaskManagerLocation> locationPreferences) |
void |
SlotPool.connectToResourceManager(UUID resourceManagerLeaderId,
ResourceManagerGateway resourceManagerGateway) |
void |
SlotPool.disconnectResourceManager() |
void |
SlotPool.failAllocation(AllocationID allocationID,
Exception cause)
Fail the specified allocation and release the corresponding slot if we have one.
|
boolean |
SlotPool.offerSlot(AllocatedSlot slot)
Slot offering by TaskManager with AllocationID.
|
Iterable<SlotOffer> |
SlotPool.offerSlots(Iterable<Tuple2<AllocatedSlot,SlotOffer>> offers) |
void |
SlotPool.registerTaskManager(ResourceID resourceID)
Register TaskManager to this pool, only those slots come from registered TaskManager will be considered valid.
|
void |
SlotPool.releaseTaskManager(ResourceID resourceID)
Unregister TaskManager from this pool, all the related slots will be released and tasks be canceled.
|
void |
SlotPool.returnAllocatedSlot(Slot slot) |
void |
SlotPool.suspend()
Suspends this pool, meaning it has lost its authority to accept and distribute slots.
|
Modifier and Type | Method and Description |
---|---|
void |
JobMaster.acknowledgeCheckpoint(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointMetrics checkpointMetrics,
SubtaskState checkpointState) |
void |
JobMaster.declineCheckpoint(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointID,
Throwable reason) |
void |
JobMaster.disconnectResourceManager(UUID jobManagerLeaderId,
UUID resourceManagerLeaderId,
Exception cause) |
void |
JobMaster.disconnectTaskManager(ResourceID resourceID,
Exception cause) |
void |
JobMaster.failSlot(ResourceID taskManagerId,
AllocationID allocationId,
UUID leaderId,
Exception cause) |
void |
JobMaster.heartbeatFromResourceManager(ResourceID resourceID) |
void |
JobMaster.heartbeatFromTaskManager(ResourceID resourceID) |
KvStateLocation |
JobMaster.lookupKvStateLocation(String registrationName) |
void |
JobMaster.notifyKvStateRegistered(JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName,
KvStateID kvStateId,
KvStateServerAddress kvStateServerAddress) |
void |
JobMaster.notifyKvStateUnregistered(JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName) |
Future<Iterable<SlotOffer>> |
JobMaster.offerSlots(ResourceID taskManagerId,
Iterable<SlotOffer> slots,
UUID leaderId) |
Future<RegistrationResponse> |
JobMaster.registerTaskManager(String taskManagerRpcAddress,
TaskManagerLocation taskManagerLocation,
UUID leaderId) |
ClassloadingProps |
JobMaster.requestClassloadingProps() |
SerializedInputSplit |
JobMaster.requestNextInputSplit(UUID leaderSessionID,
JobVertexID vertexID,
ExecutionAttemptID executionAttempt) |
ExecutionState |
JobMaster.requestPartitionState(UUID leaderSessionID,
IntermediateDataSetID intermediateResultId,
ResultPartitionID resultPartitionId) |
Acknowledge |
JobMaster.scheduleOrUpdateConsumers(UUID leaderSessionID,
ResultPartitionID partitionID) |
void |
JobMaster.startJobExecution() |
void |
JobMaster.suspendExecution(Throwable cause)
Suspending job, all the running tasks will be cancelled, and communication with other components
will be disposed.
|
Acknowledge |
JobMaster.updateTaskExecutionState(UUID leaderSessionID,
TaskExecutionState taskExecutionState)
Updates the task execution state for a given task.
|
Modifier and Type | Method and Description |
---|---|
void |
ResourceManager.disconnectJobManager(JobID jobId,
Exception cause) |
void |
ResourceManager.disconnectTaskManager(ResourceID resourceId,
Exception cause) |
Integer |
ResourceManager.getNumberOfRegisteredTaskManagers(UUID requestLeaderSessionId) |
void |
ResourceManager.heartbeatFromJobManager(ResourceID resourceID) |
void |
ResourceManager.heartbeatFromTaskManager(ResourceID resourceID) |
void |
ResourceManager.notifySlotAvailable(UUID resourceManagerLeaderId,
InstanceID instanceID,
SlotID slotId,
AllocationID allocationId)
Notification from a TaskExecutor that a slot has become available
|
void |
ResourceManager.registerInfoMessageListener(String address)
Registers an info message listener
|
Future<RegistrationResponse> |
ResourceManager.registerJobManager(UUID resourceManagerLeaderId,
UUID jobManagerLeaderId,
ResourceID jobManagerResourceId,
String jobManagerAddress,
JobID jobId) |
Future<RegistrationResponse> |
ResourceManager.registerTaskExecutor(UUID resourceManagerLeaderId,
String taskExecutorAddress,
ResourceID taskExecutorResourceId,
SlotReport slotReport)
Register a
TaskExecutor at the resource manager |
Acknowledge |
ResourceManager.requestSlot(UUID jobMasterLeaderID,
UUID resourceManagerLeaderID,
SlotRequest slotRequest)
Requests a slot from the resource manager.
|
void |
ResourceManager.shutDownCluster(ApplicationStatus finalStatus,
String optionalDiagnostics)
Cleanup application and shut down cluster
|
void |
ResourceManager.unRegisterInfoMessageListener(String address)
Unregisters an info message listener
|
Modifier and Type | Method and Description |
---|---|
Acknowledge |
TaskExecutor.cancelTask(ExecutionAttemptID executionAttemptID) |
Acknowledge |
TaskExecutor.confirmCheckpoint(ExecutionAttemptID executionAttemptID,
long checkpointId,
long checkpointTimestamp) |
void |
TaskExecutor.disconnectJobManager(JobID jobId,
Exception cause) |
void |
TaskExecutor.disconnectResourceManager(Exception cause) |
void |
TaskExecutor.failPartition(ExecutionAttemptID executionAttemptID) |
void |
TaskExecutor.heartbeatFromJobManager(ResourceID resourceID) |
void |
TaskExecutor.heartbeatFromResourceManager(ResourceID resourceID) |
Acknowledge |
TaskExecutor.requestSlot(SlotID slotId,
JobID jobId,
AllocationID allocationId,
String targetAddress,
UUID rmLeaderId)
Requests a slot from the TaskManager
|
Acknowledge |
TaskExecutor.stopTask(ExecutionAttemptID executionAttemptID) |
Acknowledge |
TaskExecutor.submitTask(TaskDeploymentDescriptor tdd,
UUID jobManagerLeaderId) |
Acknowledge |
TaskExecutor.triggerCheckpoint(ExecutionAttemptID executionAttemptID,
long checkpointId,
long checkpointTimestamp,
CheckpointOptions checkpointOptions) |
Acknowledge |
TaskExecutor.updatePartitions(ExecutionAttemptID executionAttemptID,
Iterable<PartitionInfo> partitionInfos) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.