org.apache.flink.runtime.messages

Class TaskMessages.FailTask

java.lang.Object

org.apache.flink.runtime.messages.TaskMessages.FailTask

All Implemented Interfaces:

Serializable, TaskMessages.TaskMessage, scala.Equals, scala.Product

Enclosing class:

TaskMessages

public static class TaskMessages.FailTask
extends Object
implements TaskMessages.TaskMessage, scala.Product, scala.Serializable

Triggers a fail of specified task from the outside (as opposed to the task throwing an exception itself) with the given exception as the cause.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
FailTask(ExecutionAttemptID executionID, Throwable cause)

Method Summary

Modifier and Type	Method and Description
Throwable	cause()
ExecutionAttemptID	executionID()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface scala.Product

productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

FailTask

public FailTask(ExecutionAttemptID executionID,
                Throwable cause)

Method Detail

executionID

public ExecutionAttemptID executionID()

cause

public Throwable cause()