public interface PartitionProducerStateChecker
These checks are triggered when a partition request is answered with a PartitionNotFound event. This usually happens when the producer of that partition has not registered itself with the network stack or terminated.
Modifier and Type | Method and Description |
---|---|
void |
requestPartitionProducerState(JobID jobId,
ExecutionAttemptID receiverExecutionId,
IntermediateDataSetID intermediateDataSetId,
ResultPartitionID resultPartitionId)
Requests the execution state of the execution producing a result partition.
|
void requestPartitionProducerState(JobID jobId, ExecutionAttemptID receiverExecutionId, IntermediateDataSetID intermediateDataSetId, ResultPartitionID resultPartitionId)
jobId
- ID of the job the partition belongs to.receiverExecutionId
- The execution attempt ID of the task who triggers the request.intermediateDataSetId
- ID of the parent intermediate data set.resultPartitionId
- ID of the result partition to check. ThisCopyright © 2014–2017 The Apache Software Foundation. All rights reserved.