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|
Requests the execution state of the execution producing a result partition.
CompletableFuture<ExecutionState> requestPartitionProducerState(JobID jobId, IntermediateDataSetID intermediateDataSetId, ResultPartitionID resultPartitionId)
jobId- ID of the job the partition belongs to.
intermediateDataSetId- ID of the parent intermediate data set.
resultPartitionId- ID of the result partition to check. This identifies the producing execution and partition.
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.