org.apache.reef.driver.task

Class FailedTask

java.lang.Object

org.apache.reef.common.AbstractFailure

org.apache.reef.driver.task.FailedTask

All Implemented Interfaces:

Failure, Identifiable

public final class FailedTask
extends AbstractFailure

An error message that REEF Driver gets from a failed Task.

Constructor Summary

Constructors

Constructor and Description
FailedTask(String id, String message, Optional<String> description, Optional<Throwable> cause, Optional<byte[]> data, Optional<ActiveContext> context)

Method Summary

Methods

Modifier and Type	Method and Description
Optional<ActiveContext>	getActiveContext() Access the context the task ran (and crashed) on, if it could be recovered.

Methods inherited from class org.apache.reef.common.AbstractFailure

asError, getData, getDescription, getId, getMessage, getReason, toString

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

FailedTask

public FailedTask(String id,
          String message,
          Optional<String> description,
          Optional<Throwable> cause,
          Optional<byte[]> data,
          Optional<ActiveContext> context)

Parameters:

id - Identifier of the entity that produced the error. Cannot be null.

message - One-line error message. Cannot be null.

description - Long error description. Can be null.

cause - Java Exception that caused the error. Can be null.

data - byte array that contains serialized version of the error. Can be null.

context - the Context the Task failed on.

Method Detail

getActiveContext

public Optional<ActiveContext> getActiveContext()

Access the context the task ran (and crashed) on, if it could be recovered.

An ActiveContext is given when the task fails but the context remains alive. On context failure, the context also fails and is surfaced via the FailedContext event.

Note that receiving an ActiveContext here is no guarantee that the context (and evaluator) are in a consistent state. Application developers need to investigate the reason available via getCause() to make that call.

Returns:

the context the Task ran on.