|Modifier and Type||Method and Description|
Fail the owning task with the given throwable.
Check the execution state of the execution producing a result partition.
void triggerPartitionProducerStateCheck(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.
void failExternally(Throwable cause)
cause- of the failure
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.