Modifier and Type | Field and Description |
---|---|
protected ExecutionAttemptID |
AccumulatorRegistry.taskID |
Modifier and Type | Method and Description |
---|---|
ExecutionAttemptID |
AccumulatorSnapshot.getExecutionAttemptID() |
Constructor and Description |
---|
AccumulatorRegistry(JobID jobID,
ExecutionAttemptID taskID) |
AccumulatorSnapshot(JobID jobID,
ExecutionAttemptID executionAttemptID,
Map<String,Accumulator<?,?>> userAccumulators) |
Modifier and Type | Method and Description |
---|---|
void |
CheckpointCoordinatorGateway.acknowledgeCheckpoint(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointMetrics checkpointMetrics,
SerializedValue<TaskStateSnapshot> subtaskState) |
PendingCheckpoint.TaskAcknowledgeResult |
PendingCheckpoint.acknowledgeTask(ExecutionAttemptID executionAttemptId,
TaskStateSnapshot operatorSubtaskStates,
CheckpointMetrics metrics)
Acknowledges the task with the given execution attempt id and the given subtask state.
|
void |
CheckpointFailureManager.FailJobCallback.failJobDueToTaskFailure(Throwable cause,
ExecutionAttemptID failingTask)
Fails the whole job graph due to task failure.
|
void |
CheckpointCoordinator.failUnacknowledgedPendingCheckpointsFor(ExecutionAttemptID executionAttemptId,
Throwable cause)
Fails all pending checkpoints which have not been acknowledged by the given execution attempt
id.
|
Optional<ExecutionVertex> |
ExecutionAttemptMappingProvider.getVertex(ExecutionAttemptID id) |
void |
CheckpointFailureManager.handleCheckpointException(PendingCheckpoint pendingCheckpoint,
CheckpointProperties checkpointProperties,
CheckpointException exception,
ExecutionAttemptID executionAttemptID,
JobID job,
PendingCheckpointStats pendingCheckpointStats,
CheckpointStatsTracker statsTracker)
Failures on JM:
all checkpoints - go against failure counter.
|
boolean |
PendingCheckpoint.isAcknowledgedBy(ExecutionAttemptID executionAttemptId) |
void |
CheckpointCoordinatorGateway.reportCheckpointMetrics(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointMetrics checkpointMetrics) |
void |
CheckpointCoordinator.reportStats(long id,
ExecutionAttemptID attemptId,
CheckpointMetrics metrics) |
Modifier and Type | Method and Description |
---|---|
ExecutionAttemptID |
TaskDeploymentDescriptor.getExecutionAttemptId() |
Constructor and Description |
---|
TaskDeploymentDescriptor(JobID jobId,
TaskDeploymentDescriptor.MaybeOffloaded<JobInformation> serializedJobInformation,
TaskDeploymentDescriptor.MaybeOffloaded<TaskInformation> serializedTaskInformation,
ExecutionAttemptID executionAttemptId,
AllocationID allocationId,
JobManagerTaskRestore taskRestore,
List<ResultPartitionDeploymentDescriptor> resultPartitionDeploymentDescriptors,
List<InputGateDeploymentDescriptor> inputGateDeploymentDescriptors) |
Modifier and Type | Method and Description |
---|---|
ExecutionAttemptID |
Environment.getExecutionId()
Gets the ID of the task execution attempt.
|
Modifier and Type | Method and Description |
---|---|
static ExecutionAttemptID |
ExecutionAttemptID.fromByteBuf(org.apache.flink.shaded.netty4.io.netty.buffer.ByteBuf buf) |
ExecutionAttemptID |
Execution.getAttemptId() |
ExecutionAttemptID |
AccessExecution.getAttemptId()
Returns the
ExecutionAttemptID for this Execution. |
ExecutionAttemptID |
ArchivedExecution.getAttemptId() |
ExecutionAttemptID |
TaskExecutionStateTransition.getID() |
static ExecutionAttemptID |
ExecutionAttemptID.randomId() |
Modifier and Type | Method and Description |
---|---|
Map<ExecutionAttemptID,Execution> |
DefaultExecutionGraph.getRegisteredExecutions() |
Map<ExecutionAttemptID,Execution> |
ExecutionGraph.getRegisteredExecutions() |
Modifier and Type | Method and Description |
---|---|
void |
SpeculativeExecutionVertex.archiveFailedExecution(ExecutionAttemptID executionAttemptId)
Remove execution from currentExecutions if it is failed.
|
Optional<AccessExecution> |
DefaultExecutionGraph.findExecution(ExecutionAttemptID attemptId) |
Optional<AccessExecution> |
ExecutionGraph.findExecution(ExecutionAttemptID attemptId) |
Optional<String> |
DefaultExecutionGraph.findVertexWithAttempt(ExecutionAttemptID attemptId) |
Optional<String> |
ExecutionGraph.findVertexWithAttempt(ExecutionAttemptID attemptId) |
void |
DefaultExecutionGraph.notifySchedulerNgAboutInternalTaskFailure(ExecutionAttemptID attemptId,
Throwable t,
boolean cancelTask,
boolean releasePartitions) |
void |
InternalExecutionGraphAccessor.notifySchedulerNgAboutInternalTaskFailure(ExecutionAttemptID attemptId,
Throwable t,
boolean cancelTask,
boolean releasePartitions) |
void |
ExecutionDeploymentListener.onCompletedDeployment(ExecutionAttemptID execution) |
void |
NoOpExecutionDeploymentListener.onCompletedDeployment(ExecutionAttemptID execution) |
void |
ExecutionDeploymentListener.onStartedDeployment(ExecutionAttemptID execution,
ResourceID host) |
void |
NoOpExecutionDeploymentListener.onStartedDeployment(ExecutionAttemptID execution,
ResourceID host) |
void |
ExecutionStateUpdateListener.onStateUpdate(ExecutionAttemptID execution,
ExecutionState previousState,
ExecutionState newState) |
Constructor and Description |
---|
ArchivedExecution(StringifiedAccumulatorResult[] userAccumulators,
IOMetrics ioMetrics,
ExecutionAttemptID attemptId,
ExecutionState state,
ErrorInfo failureCause,
TaskManagerLocation assignedResourceLocation,
AllocationID assignedAllocationID,
long[] stateTimestamps,
long[] stateEndTimestamps) |
Modifier and Type | Method and Description |
---|---|
Future<Path> |
FileCache.createTmpFile(String name,
DistributedCache.DistributedCacheEntry entry,
JobID jobID,
ExecutionAttemptID executionId)
If the file doesn't exists locally, retrieve the file from the blob-service.
|
void |
FileCache.releaseJob(JobID jobId,
ExecutionAttemptID executionId) |
Modifier and Type | Method and Description |
---|---|
ShuffleIOOwnerContext |
NettyShuffleEnvironment.createShuffleIOOwnerContext(String ownerName,
ExecutionAttemptID executionAttemptID,
MetricGroup parentGroup) |
boolean |
NettyShuffleEnvironment.updatePartitionInfo(ExecutionAttemptID consumerID,
PartitionInfo partitionInfo) |
Modifier and Type | Method and Description |
---|---|
ExecutionAttemptID |
ResultPartitionID.getProducerId() |
Constructor and Description |
---|
ResultPartitionID(IntermediateResultPartitionID partitionId,
ExecutionAttemptID producerId) |
Modifier and Type | Method and Description |
---|---|
ExecutionAttemptID |
InputGateID.getConsumerID() |
Constructor and Description |
---|
InputGateID(IntermediateDataSetID consumedResultID,
ExecutionAttemptID consumerID) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Acknowledge> |
TaskManagerGateway.cancelTask(ExecutionAttemptID executionAttemptID,
Time timeout)
Cancel the given task.
|
void |
TaskManagerGateway.notifyCheckpointAborted(ExecutionAttemptID executionAttemptID,
JobID jobId,
long checkpointId,
long latestCompletedCheckpointId,
long timestamp)
Notify the given task about a aborted checkpoint.
|
void |
TaskManagerGateway.notifyCheckpointOnComplete(ExecutionAttemptID executionAttemptID,
JobID jobId,
long completedCheckpointId,
long completedTimestamp,
long lastSubsumedCheckpointId)
Notify the given task about a completed checkpoint and the last subsumed checkpoint id if
possible.
|
CompletableFuture<Acknowledge> |
TaskManagerGateway.sendOperatorEventToTask(ExecutionAttemptID task,
OperatorID operator,
SerializedValue<OperatorEvent> evt) |
CompletableFuture<Acknowledge> |
TaskManagerGateway.triggerCheckpoint(ExecutionAttemptID executionAttemptID,
JobID jobId,
long checkpointId,
long timestamp,
CheckpointOptions checkpointOptions)
Trigger for the given task a checkpoint.
|
CompletableFuture<Acknowledge> |
TaskManagerGateway.updatePartitions(ExecutionAttemptID executionAttemptID,
Iterable<PartitionInfo> partitionInfos,
Time timeout)
Update the task where the given partitions can be found.
|
Modifier and Type | Method and Description |
---|---|
Map<ExecutionAttemptID,ExecutionDeploymentState> |
DefaultExecutionDeploymentTracker.getExecutionsOn(ResourceID host) |
Map<ExecutionAttemptID,ExecutionDeploymentState> |
ExecutionDeploymentTracker.getExecutionsOn(ResourceID host)
Returns all tracked executions for the given host.
|
Modifier and Type | Method and Description |
---|---|
void |
JobMaster.acknowledgeCheckpoint(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointMetrics checkpointMetrics,
SerializedValue<TaskStateSnapshot> checkpointState) |
CompletableFuture<Acknowledge> |
RpcTaskManagerGateway.cancelTask(ExecutionAttemptID executionAttemptID,
Time timeout) |
void |
DefaultExecutionDeploymentTracker.completeDeploymentOf(ExecutionAttemptID executionAttemptId) |
void |
ExecutionDeploymentTracker.completeDeploymentOf(ExecutionAttemptID executionAttemptId)
Marks the deployment of the given execution as complete.
|
void |
RpcTaskManagerGateway.notifyCheckpointAborted(ExecutionAttemptID executionAttemptID,
JobID jobId,
long checkpointId,
long latestCompletedCheckpointId,
long timestamp) |
void |
RpcTaskManagerGateway.notifyCheckpointOnComplete(ExecutionAttemptID executionAttemptID,
JobID jobId,
long completedCheckpointId,
long completedTimestamp,
long lastSubsumedCheckpointId) |
void |
ExecutionDeploymentTrackerDeploymentListenerAdapter.onCompletedDeployment(ExecutionAttemptID execution) |
void |
ExecutionDeploymentTrackerDeploymentListenerAdapter.onStartedDeployment(ExecutionAttemptID execution,
ResourceID host) |
void |
JobMaster.reportCheckpointMetrics(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointMetrics checkpointMetrics) |
CompletableFuture<SerializedInputSplit> |
JobMaster.requestNextInputSplit(JobVertexID vertexID,
ExecutionAttemptID executionAttempt) |
CompletableFuture<SerializedInputSplit> |
JobMasterGateway.requestNextInputSplit(JobVertexID vertexID,
ExecutionAttemptID executionAttempt)
Requests the next input split for the
ExecutionJobVertex . |
CompletableFuture<Acknowledge> |
JobMaster.sendOperatorEventToCoordinator(ExecutionAttemptID task,
OperatorID operatorID,
SerializedValue<OperatorEvent> serializedEvent) |
CompletableFuture<Acknowledge> |
JobMasterOperatorEventGateway.sendOperatorEventToCoordinator(ExecutionAttemptID task,
OperatorID operatorID,
SerializedValue<OperatorEvent> event) |
CompletableFuture<Acknowledge> |
RpcTaskManagerGateway.sendOperatorEventToTask(ExecutionAttemptID task,
OperatorID operator,
SerializedValue<OperatorEvent> evt) |
void |
DefaultExecutionDeploymentTracker.startTrackingPendingDeploymentOf(ExecutionAttemptID executionAttemptId,
ResourceID host) |
void |
ExecutionDeploymentTracker.startTrackingPendingDeploymentOf(ExecutionAttemptID executionAttemptId,
ResourceID host)
Starts tracking the given execution that is being deployed on the given host.
|
void |
DefaultExecutionDeploymentTracker.stopTrackingDeploymentOf(ExecutionAttemptID executionAttemptId) |
void |
ExecutionDeploymentTracker.stopTrackingDeploymentOf(ExecutionAttemptID executionAttemptId)
Stops tracking the given execution.
|
CompletableFuture<Acknowledge> |
RpcTaskManagerGateway.triggerCheckpoint(ExecutionAttemptID executionAttemptID,
JobID jobId,
long checkpointId,
long timestamp,
CheckpointOptions checkpointOptions) |
CompletableFuture<Acknowledge> |
RpcTaskManagerGateway.updatePartitions(ExecutionAttemptID executionAttemptID,
Iterable<PartitionInfo> partitionInfos,
Time timeout) |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionDeploymentReconciliationHandler.onMissingDeploymentsOf(Collection<ExecutionAttemptID> executionAttemptIds,
ResourceID hostingTaskExecutor)
Called if some executions are expected to be hosted on a task executor, but aren't.
|
void |
ExecutionDeploymentReconciliationHandler.onUnknownDeploymentsOf(Collection<ExecutionAttemptID> executionAttemptIds,
ResourceID hostingTaskExecutor)
Called if some executions are hosted on a task executor, but we don't expect them.
|
void |
ExecutionDeploymentReconciler.reconcileExecutionDeployments(ResourceID taskExecutorHost,
ExecutionDeploymentReport executionDeploymentReport,
Map<ExecutionAttemptID,ExecutionDeploymentState> expectedDeployedExecutionIds)
Reconciles the deployment states between all reported/expected executions for the given task
executor.
|
void |
DefaultExecutionDeploymentReconciler.reconcileExecutionDeployments(ResourceID taskExecutorHost,
ExecutionDeploymentReport executionDeploymentReport,
Map<ExecutionAttemptID,ExecutionDeploymentState> expectedDeployedExecutions) |
Modifier and Type | Method and Description |
---|---|
ExecutionAttemptID |
TaskBackPressureResponse.getExecutionAttemptID() |
Constructor and Description |
---|
TaskBackPressureResponse(int requestId,
ExecutionAttemptID executionAttemptID,
double backPressureRatio) |
Modifier and Type | Method and Description |
---|---|
ExecutionAttemptID |
AbstractCheckpointMessage.getTaskExecutionId() |
Constructor and Description |
---|
AbstractCheckpointMessage(JobID job,
ExecutionAttemptID taskExecutionId,
long checkpointId) |
AcknowledgeCheckpoint(JobID jobId,
ExecutionAttemptID taskExecutionId,
long checkpointId) |
AcknowledgeCheckpoint(JobID job,
ExecutionAttemptID taskExecutionId,
long checkpointId,
CheckpointMetrics checkpointMetrics,
TaskStateSnapshot subtaskState) |
DeclineCheckpoint(JobID job,
ExecutionAttemptID taskExecutionId,
long checkpointId,
CheckpointException checkpointException) |
Modifier and Type | Method and Description |
---|---|
ExecutionAttemptID |
TaskMetricGroup.executionId() |
Modifier and Type | Method and Description |
---|---|
TaskMetricGroup |
TaskManagerJobMetricGroup.addTask(ExecutionAttemptID executionAttemptID,
String taskName) |
TaskMetricGroup |
UnregisteredMetricGroups.UnregisteredTaskManagerJobMetricGroup.addTask(ExecutionAttemptID executionAttemptID,
String taskName) |
void |
TaskManagerJobMetricGroup.removeTaskMetricGroup(ExecutionAttemptID executionId) |
Modifier and Type | Method and Description |
---|---|
String[] |
TaskScopeFormat.formatScope(TaskManagerJobMetricGroup parent,
AbstractID vertexId,
ExecutionAttemptID attemptId,
String taskName,
int subtask,
int attemptNumber) |
Modifier and Type | Method and Description |
---|---|
ExecutionAttemptID |
OperatorCoordinator.SubtaskGateway.getExecution()
Gets the execution attempt for the subtask execution attempt that this gateway
communicates with.
|
Modifier and Type | Method and Description |
---|---|
void |
ExecutionGraphHandler.acknowledgeCheckpoint(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointMetrics checkpointMetrics,
TaskStateSnapshot checkpointState) |
void |
SchedulerNG.acknowledgeCheckpoint(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointMetrics checkpointMetrics,
TaskStateSnapshot checkpointState) |
void |
SchedulerBase.acknowledgeCheckpoint(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointMetrics checkpointMetrics,
TaskStateSnapshot checkpointState) |
void |
ExecutionSlotAllocator.cancel(ExecutionAttemptID executionAttemptId)
Cancel the ongoing slot request of the given
Execution . |
void |
SimpleExecutionSlotAllocator.cancel(ExecutionAttemptID executionAttemptId) |
void |
DefaultOperatorCoordinatorHandler.deliverOperatorEventToCoordinator(ExecutionAttemptID taskExecutionId,
OperatorID operatorId,
OperatorEvent evt) |
void |
SchedulerNG.deliverOperatorEventToCoordinator(ExecutionAttemptID taskExecution,
OperatorID operator,
OperatorEvent evt)
Delivers the given OperatorEvent to the
OperatorCoordinator with the given OperatorID . |
void |
OperatorCoordinatorHandler.deliverOperatorEventToCoordinator(ExecutionAttemptID taskExecutionId,
OperatorID operatorId,
OperatorEvent event)
Delivers an OperatorEvent to a
OperatorCoordinator . |
void |
SchedulerBase.deliverOperatorEventToCoordinator(ExecutionAttemptID taskExecutionId,
OperatorID operatorId,
OperatorEvent evt) |
void |
InternalFailuresListener.notifyTaskFailure(ExecutionAttemptID attemptId,
Throwable t,
boolean cancelTask,
boolean releasePartitions) |
void |
UpdateSchedulerNgOnInternalFailuresListener.notifyTaskFailure(ExecutionAttemptID attemptId,
Throwable t,
boolean cancelTask,
boolean releasePartitions) |
void |
ExecutionGraphHandler.reportCheckpointMetrics(ExecutionAttemptID attemptId,
long id,
CheckpointMetrics metrics) |
void |
SchedulerNG.reportCheckpointMetrics(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointMetrics checkpointMetrics) |
void |
SchedulerBase.reportCheckpointMetrics(JobID jobID,
ExecutionAttemptID attemptId,
long id,
CheckpointMetrics metrics) |
SerializedInputSplit |
ExecutionGraphHandler.requestNextInputSplit(JobVertexID vertexID,
ExecutionAttemptID executionAttempt) |
SerializedInputSplit |
SchedulerNG.requestNextInputSplit(JobVertexID vertexID,
ExecutionAttemptID executionAttempt) |
SerializedInputSplit |
SchedulerBase.requestNextInputSplit(JobVertexID vertexID,
ExecutionAttemptID executionAttempt) |
Modifier and Type | Method and Description |
---|---|
List<org.apache.flink.runtime.scheduler.ExecutionSlotAssignment> |
ExecutionSlotAllocator.allocateSlotsFor(List<ExecutionAttemptID> executionAttemptIds)
Allocate slots for the given executions.
|
List<org.apache.flink.runtime.scheduler.ExecutionSlotAssignment> |
SimpleExecutionSlotAllocator.allocateSlotsFor(List<ExecutionAttemptID> executionAttemptIds) |
Modifier and Type | Method and Description |
---|---|
void |
AdaptiveScheduler.acknowledgeCheckpoint(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointMetrics checkpointMetrics,
TaskStateSnapshot checkpointState) |
void |
AdaptiveScheduler.deliverOperatorEventToCoordinator(ExecutionAttemptID taskExecution,
OperatorID operator,
OperatorEvent evt) |
void |
AdaptiveScheduler.reportCheckpointMetrics(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointMetrics checkpointMetrics) |
SerializedInputSplit |
AdaptiveScheduler.requestNextInputSplit(JobVertexID vertexID,
ExecutionAttemptID executionAttempt) |
Modifier and Type | Method and Description |
---|---|
void |
SpeculativeScheduler.notifySlowTasks(Map<ExecutionVertexID,Collection<ExecutionAttemptID>> slowTasks) |
Modifier and Type | Method and Description |
---|---|
void |
DeploymentStateTimeMetrics.onStateUpdate(ExecutionAttemptID execution,
ExecutionState previousState,
ExecutionState newState) |
Modifier and Type | Method and Description |
---|---|
void |
SlowTaskDetectorListener.notifySlowTasks(Map<ExecutionVertexID,Collection<ExecutionAttemptID>> slowTasks)
Notify detected slow tasks.
|
Modifier and Type | Method and Description |
---|---|
ExecutionAttemptID |
ShuffleIOOwnerContext.getExecutionAttemptID() |
ExecutionAttemptID |
ProducerDescriptor.getProducerExecutionId() |
Modifier and Type | Method and Description |
---|---|
static ProducerDescriptor |
ProducerDescriptor.create(TaskManagerLocation producerLocation,
ExecutionAttemptID attemptId) |
ShuffleIOOwnerContext |
ShuffleEnvironment.createShuffleIOOwnerContext(String ownerName,
ExecutionAttemptID executionAttemptID,
MetricGroup parentGroup)
Create a context of the shuffle input/output owner used to create partitions or gates
belonging to the owner.
|
boolean |
ShuffleEnvironment.updatePartitionInfo(ExecutionAttemptID consumerID,
PartitionInfo partitionInfo)
Update a gate with the newly available partition information, previously unknown.
|
Constructor and Description |
---|
ProducerDescriptor(ResourceID producerLocation,
ExecutionAttemptID producerExecutionId,
InetAddress address,
int dataPort) |
ShuffleIOOwnerContext(String ownerName,
ExecutionAttemptID executionAttemptID,
MetricGroup parentGroup,
MetricGroup outputGroup,
MetricGroup inputGroup) |
Constructor and Description |
---|
TaskStateManagerImpl(JobID jobId,
ExecutionAttemptID executionAttemptID,
TaskLocalStateStore localStateStore,
StateChangelogStorage<?> stateChangelogStorage,
TaskExecutorStateChangelogStoragesManager changelogStoragesManager,
JobManagerTaskRestore jobManagerTaskRestore,
CheckpointResponder checkpointResponder) |
TaskStateManagerImpl(JobID jobId,
ExecutionAttemptID executionAttemptID,
TaskLocalStateStore localStateStore,
StateChangelogStorage<?> stateChangelogStorage,
TaskExecutorStateChangelogStoragesManager changelogStoragesManager,
JobManagerTaskRestore jobManagerTaskRestore,
CheckpointResponder checkpointResponder,
SequentialChannelStateReaderImpl sequentialChannelStateReader) |
Modifier and Type | Method and Description |
---|---|
Set<ExecutionAttemptID> |
ExecutionDeploymentReport.getExecutions() |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Acknowledge> |
TaskExecutorGatewayDecoratorBase.abortCheckpoint(ExecutionAttemptID executionAttemptID,
long checkpointId,
long latestCompletedCheckpointId,
long checkpointTimestamp) |
CompletableFuture<Acknowledge> |
TaskExecutorGateway.abortCheckpoint(ExecutionAttemptID executionAttemptID,
long checkpointId,
long latestCompletedCheckpointId,
long checkpointTimestamp)
Abort a checkpoint for the given task.
|
CompletableFuture<Acknowledge> |
TaskExecutor.abortCheckpoint(ExecutionAttemptID executionAttemptID,
long checkpointId,
long latestCompletedCheckpointId,
long checkpointTimestamp) |
CompletableFuture<Acknowledge> |
TaskExecutorGatewayDecoratorBase.cancelTask(ExecutionAttemptID executionAttemptID,
Time timeout) |
CompletableFuture<Acknowledge> |
TaskExecutorGateway.cancelTask(ExecutionAttemptID executionAttemptID,
Time timeout)
Cancel the given task.
|
CompletableFuture<Acknowledge> |
TaskExecutor.cancelTask(ExecutionAttemptID executionAttemptID,
Time timeout) |
CompletableFuture<Acknowledge> |
TaskExecutorGatewayDecoratorBase.confirmCheckpoint(ExecutionAttemptID executionAttemptID,
long completedCheckpointId,
long completedCheckpointTimestamp,
long lastSubsumedCheckpointId) |
CompletableFuture<Acknowledge> |
TaskExecutorGateway.confirmCheckpoint(ExecutionAttemptID executionAttemptID,
long completedCheckpointId,
long completedCheckpointTimestamp,
long lastSubsumedCheckpointId)
Confirm a checkpoint for the given task.
|
CompletableFuture<Acknowledge> |
TaskExecutor.confirmCheckpoint(ExecutionAttemptID executionAttemptID,
long completedCheckpointId,
long completedCheckpointTimestamp,
long lastSubsumedCheckpointId) |
CompletableFuture<Acknowledge> |
TaskExecutorOperatorEventGateway.sendOperatorEventToTask(ExecutionAttemptID task,
OperatorID operator,
SerializedValue<OperatorEvent> evt)
Sends an operator event to an operator in a task executed by the Task Manager (Task
Executor).
|
CompletableFuture<Acknowledge> |
TaskExecutorGatewayDecoratorBase.sendOperatorEventToTask(ExecutionAttemptID task,
OperatorID operator,
SerializedValue<OperatorEvent> evt) |
CompletableFuture<Acknowledge> |
TaskExecutorGateway.sendOperatorEventToTask(ExecutionAttemptID task,
OperatorID operator,
SerializedValue<OperatorEvent> evt) |
CompletableFuture<Acknowledge> |
TaskExecutor.sendOperatorEventToTask(ExecutionAttemptID executionAttemptID,
OperatorID operatorId,
SerializedValue<OperatorEvent> evt) |
CompletableFuture<Acknowledge> |
TaskExecutorGatewayDecoratorBase.triggerCheckpoint(ExecutionAttemptID executionAttemptID,
long checkpointID,
long checkpointTimestamp,
CheckpointOptions checkpointOptions) |
CompletableFuture<Acknowledge> |
TaskExecutorGateway.triggerCheckpoint(ExecutionAttemptID executionAttemptID,
long checkpointID,
long checkpointTimestamp,
CheckpointOptions checkpointOptions)
Trigger the checkpoint for the given task.
|
CompletableFuture<Acknowledge> |
TaskExecutor.triggerCheckpoint(ExecutionAttemptID executionAttemptID,
long checkpointId,
long checkpointTimestamp,
CheckpointOptions checkpointOptions) |
CompletableFuture<Acknowledge> |
TaskExecutorGatewayDecoratorBase.updatePartitions(ExecutionAttemptID executionAttemptID,
Iterable<PartitionInfo> partitionInfos,
Time timeout) |
CompletableFuture<Acknowledge> |
TaskExecutorGateway.updatePartitions(ExecutionAttemptID executionAttemptID,
Iterable<PartitionInfo> partitionInfos,
Time timeout)
Update the task where the given partitions can be found.
|
CompletableFuture<Acknowledge> |
TaskExecutor.updatePartitions(ExecutionAttemptID executionAttemptID,
Iterable<PartitionInfo> partitionInfos,
Time timeout) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<TaskThreadInfoResponse> |
TaskExecutorGatewayDecoratorBase.requestThreadInfoSamples(Collection<ExecutionAttemptID> taskExecutionAttemptIds,
ThreadInfoSamplesRequest requestParams,
Time timeout) |
CompletableFuture<TaskThreadInfoResponse> |
TaskExecutorThreadInfoGateway.requestThreadInfoSamples(Collection<ExecutionAttemptID> taskExecutionAttemptIds,
ThreadInfoSamplesRequest requestParams,
Time timeout)
Request a thread info sample from the given tasks.
|
CompletableFuture<TaskThreadInfoResponse> |
TaskExecutor.requestThreadInfoSamples(Collection<ExecutionAttemptID> taskExecutionAttemptIds,
ThreadInfoSamplesRequest requestParams,
Time timeout) |
Constructor and Description |
---|
ExecutionDeploymentReport(Set<ExecutionAttemptID> executions) |
Modifier and Type | Method and Description |
---|---|
void |
RpcCheckpointResponder.acknowledgeCheckpoint(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointMetrics checkpointMetrics,
TaskStateSnapshot subtaskState) |
void |
RpcCheckpointResponder.declineCheckpoint(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointException checkpointException) |
void |
RpcCheckpointResponder.reportCheckpointMetrics(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointMetrics checkpointMetrics) |
Constructor and Description |
---|
RpcInputSplitProvider(JobMasterGateway jobMasterGateway,
JobVertexID jobVertexID,
ExecutionAttemptID executionAttemptID,
Time timeout) |
RpcTaskOperatorEventGateway(JobMasterOperatorEventGateway rpcGateway,
ExecutionAttemptID taskExecutionId,
java.util.function.Consumer<Throwable> errorHandler) |
Modifier and Type | Method and Description |
---|---|
ExecutionAttemptID |
TaskSlotPayload.getExecutionId() |
Modifier and Type | Method and Description |
---|---|
T |
TaskSlotTableImpl.getTask(ExecutionAttemptID executionAttemptID) |
T |
TaskSlotTable.getTask(ExecutionAttemptID executionAttemptID)
Get the task for the given execution attempt id.
|
T |
TaskSlot.remove(ExecutionAttemptID executionAttemptId)
Remove the task identified by the given execution attempt id.
|
T |
TaskSlotTableImpl.removeTask(ExecutionAttemptID executionAttemptID) |
T |
TaskSlotTable.removeTask(ExecutionAttemptID executionAttemptID)
Remove the task with the given execution attempt id from its task slot.
|
Modifier and Type | Method and Description |
---|---|
ExecutionAttemptID |
RuntimeEnvironment.getExecutionId() |
ExecutionAttemptID |
Task.getExecutionId() |
ExecutionAttemptID |
TaskExecutionState.getID()
Returns the ID of the task this result belongs to
|
Modifier and Type | Method and Description |
---|---|
void |
CheckpointResponder.acknowledgeCheckpoint(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointMetrics checkpointMetrics,
TaskStateSnapshot subtaskState)
Acknowledges the given checkpoint.
|
void |
CheckpointResponder.declineCheckpoint(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointException checkpointException)
Declines the given checkpoint.
|
void |
TaskManagerActions.failTask(ExecutionAttemptID executionAttemptID,
Throwable cause)
Tells the task manager to fail the given task.
|
void |
CheckpointResponder.reportCheckpointMetrics(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointMetrics checkpointMetrics)
Report metrics for the given checkpoint.
|
Constructor and Description |
---|
RuntimeEnvironment(JobID jobId,
JobVertexID jobVertexId,
ExecutionAttemptID executionId,
ExecutionConfig executionConfig,
TaskInfo taskInfo,
Configuration jobConfiguration,
Configuration taskConfiguration,
UserCodeClassLoader userCodeClassLoader,
MemoryManager memManager,
IOManager ioManager,
BroadcastVariableManager bcVarManager,
TaskStateManager taskStateManager,
GlobalAggregateManager aggregateManager,
AccumulatorRegistry accumulatorRegistry,
TaskKvStateRegistry kvStateRegistry,
InputSplitProvider splitProvider,
Map<String,Future<Path>> distCacheEntries,
ResultPartitionWriter[] writers,
IndexedInputGate[] inputGates,
TaskEventDispatcher taskEventDispatcher,
CheckpointResponder checkpointResponder,
TaskOperatorEventGateway operatorEventGateway,
TaskManagerRuntimeInfo taskManagerInfo,
TaskMetricGroup metrics,
Task containingTask,
ExternalResourceInfoProvider externalResourceInfoProvider) |
Task(JobInformation jobInformation,
TaskInformation taskInformation,
ExecutionAttemptID executionAttemptID,
AllocationID slotAllocationId,
List<ResultPartitionDeploymentDescriptor> resultPartitionDeploymentDescriptors,
List<InputGateDeploymentDescriptor> inputGateDeploymentDescriptors,
MemoryManager memManager,
IOManager ioManager,
ShuffleEnvironment<?,?> shuffleEnvironment,
KvStateService kvStateService,
BroadcastVariableManager bcVarManager,
TaskEventDispatcher taskEventDispatcher,
ExternalResourceInfoProvider externalResourceInfoProvider,
TaskStateManager taskStateManager,
TaskManagerActions taskManagerActions,
InputSplitProvider inputSplitProvider,
CheckpointResponder checkpointResponder,
TaskOperatorEventGateway operatorCoordinatorEventGateway,
GlobalAggregateManager aggregateManager,
LibraryCacheManager.ClassLoaderHandle classLoaderHandle,
FileCache fileCache,
TaskManagerRuntimeInfo taskManagerConfig,
TaskMetricGroup metricGroup,
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.
|
TaskExecutionState(ExecutionAttemptID executionId,
ExecutionState executionState)
Creates a new task execution state update, with no attached exception and no accumulators.
|
TaskExecutionState(ExecutionAttemptID executionId,
ExecutionState executionState,
Throwable error)
Creates a new task execution state update, with an attached exception but no accumulators.
|
TaskExecutionState(ExecutionAttemptID executionId,
ExecutionState executionState,
Throwable error,
AccumulatorSnapshot accumulators,
IOMetrics ioMetrics)
Creates a new task execution state update, with an attached exception.
|
Modifier and Type | Field and Description |
---|---|
protected Set<Set<ExecutionAttemptID>> |
TaskStatsRequestCoordinator.PendingStatsRequest.pendingTasks
All tasks what did not yet return a result.
|
protected Map<org.apache.flink.shaded.guava30.com.google.common.collect.ImmutableSet<ExecutionAttemptID>,T> |
TaskStatsRequestCoordinator.PendingStatsRequest.statsResultByTaskGroup
Results returned by individual tasks and stored by the tasks'
ExecutionAttemptID . |
Modifier and Type | Method and Description |
---|---|
protected void |
TaskStatsRequestCoordinator.PendingStatsRequest.collectTaskStats(org.apache.flink.shaded.guava30.com.google.common.collect.ImmutableSet<ExecutionAttemptID> executionId,
T taskStatsResult)
Collects result from one of the tasks.
|
void |
TaskStatsRequestCoordinator.handleSuccessfulResponse(int requestId,
org.apache.flink.shaded.guava30.com.google.common.collect.ImmutableSet<ExecutionAttemptID> executionIds,
T result)
Handles the successfully returned tasks stats response by collecting the corresponding
subtask samples.
|
Constructor and Description |
---|
PendingStatsRequest(int requestId,
Collection<? extends Set<ExecutionAttemptID>> tasksToCollect)
Creates new
TaskStatsRequestCoordinator.PendingStatsRequest . |
Modifier and Type | Method and Description |
---|---|
Map<org.apache.flink.shaded.guava30.com.google.common.collect.ImmutableSet<ExecutionAttemptID>,Collection<ThreadInfoSample>> |
JobVertexThreadInfoStats.getSamplesBySubtask()
Returns the a map of thread info samples by subtask (execution ID).
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<JobVertexThreadInfoStats> |
ThreadInfoRequestCoordinator.triggerThreadInfoRequest(Map<org.apache.flink.shaded.guava30.com.google.common.collect.ImmutableSet<ExecutionAttemptID>,CompletableFuture<TaskExecutorThreadInfoGateway>> executionsWithGateways,
int numSamples,
java.time.Duration delayBetweenSamples,
int maxStackTraceDepth)
Triggers collection of thread info stats of a job vertex by combining thread info responses
from given subtasks.
|
Constructor and Description |
---|
JobVertexThreadInfoStats(int requestId,
long startTime,
long endTime,
Map<org.apache.flink.shaded.guava30.com.google.common.collect.ImmutableSet<ExecutionAttemptID>,Collection<ThreadInfoSample>> samplesBySubtask)
Creates a thread details sample.
|
Modifier and Type | Method and Description |
---|---|
ExecutionAttemptID |
SavepointEnvironment.getExecutionId() |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.