org.apache.flink.runtime.taskexecutor.slot

Interface TaskSlotPayload

All Known Implementing Classes:

Task

public interface TaskSlotPayload

Payload interface for TaskSlot.

Method Summary

Modifier and Type	Method and Description
void	failExternally(Throwable cause) Fail the payload with the given throwable.
AllocationID	getAllocationId()
ExecutionAttemptID	getExecutionId()
JobID	getJobID()
CompletableFuture<?>	getTerminationFuture()

Method Detail

getJobID

JobID getJobID()

getExecutionId

ExecutionAttemptID getExecutionId()

getAllocationId

AllocationID getAllocationId()

getTerminationFuture

CompletableFuture<?> getTerminationFuture()

failExternally

void failExternally(Throwable cause)

Fail the payload with the given throwable. This operation should eventually complete the termination future.

Parameters:

cause - of the failure