org.apache.spark
Class ExceptionFailure

Object
  org.apache.spark.ExceptionFailure

All Implemented Interfaces:

java.io.Serializable, TaskEndReason, TaskFailedReason, scala.Equals, scala.Product

public class ExceptionFailure
extends Object
implements TaskFailedReason, scala.Product, scala.Serializable

:: DeveloperApi :: Task failed due to a runtime exception. This is the most common failure case and also captures user program exceptions.

stackTrace contains the stack trace of the exception itself. It still exists for backward compatibility. It's better to use this(e: Throwable, metrics: Option[TaskMetrics]) to create ExceptionFailure as it will handle the backward compatibility properly.

fullStackTrace is a better representation of the stack trace because it contains the whole stack trace including the exception and its causes

See Also:

Serialized Form

Constructor Summary

ExceptionFailure(String className, String description, StackTraceElement[] stackTrace, String fullStackTrace, scala.Option<org.apache.spark.executor.TaskMetrics> metrics)

Method Summary

String	className()
String	description()
String	fullStackTrace()
scala.Option<org.apache.spark.executor.TaskMetrics>	metrics()
StackTraceElement[]	stackTrace()
String	toErrorString() Error message displayed in the web UI.

Methods inherited from class Object

equals, 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

ExceptionFailure

public ExceptionFailure(String className,
                        String description,
                        StackTraceElement[] stackTrace,
                        String fullStackTrace,
                        scala.Option<org.apache.spark.executor.TaskMetrics> metrics)

Method Detail

className

public String className()

description

public String description()

stackTrace

public StackTraceElement[] stackTrace()

fullStackTrace

public String fullStackTrace()

metrics

public scala.Option<org.apache.spark.executor.TaskMetrics> metrics()

toErrorString

public String toErrorString()

Description copied from interface: TaskFailedReason

Error message displayed in the web UI.

Specified by:

toErrorString in interface TaskFailedReason