org.apache.flink.runtime.taskmanager

Interface TaskActions

All Known Implementing Classes:

Task

public interface TaskActions

Actions which can be performed on a Task.

Method Summary

Modifier and Type	Method and Description
void	failExternally(Throwable cause) Fail the owning task with the given throwable.
void	triggerPartitionProducerStateCheck(JobID jobId, IntermediateDataSetID intermediateDataSetId, ResultPartitionID resultPartitionId) Check the execution state of the execution producing a result partition.

Method Detail

triggerPartitionProducerStateCheck

void triggerPartitionProducerStateCheck(JobID jobId,
                                        IntermediateDataSetID intermediateDataSetId,
                                        ResultPartitionID resultPartitionId)

Check the execution state of the execution producing a result partition.

Parameters:

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.

failExternally

void failExternally(Throwable cause)

Fail the owning task with the given throwable.

Parameters:

cause - of the failure