case class
ExceptionFailure(className: String, description: String, stackTrace: Array[StackTraceElement], fullStackTrace: String, metrics: Option[TaskMetrics], exceptionWrapper: Option[ThrowableSerializationWrapper]) extends TaskFailedReason with Product with Serializable
Instance Constructors
-
new
ExceptionFailure(className: String, description: String, stackTrace: Array[StackTraceElement], fullStackTrace: String, metrics: Option[TaskMetrics], exceptionWrapper: Option[ThrowableSerializationWrapper])
Value Members
-
final
def
!=(arg0: AnyRef): Boolean
-
final
def
!=(arg0: Any): Boolean
-
final
def
##(): Int
-
final
def
==(arg0: AnyRef): Boolean
-
final
def
==(arg0: Any): Boolean
-
final
def
asInstanceOf[T0]: T0
-
val
className: String
-
def
clone(): AnyRef
-
def
countTowardsTaskFailures: Boolean
-
val
description: String
-
final
def
eq(arg0: AnyRef): Boolean
-
def
exception: Option[Throwable]
-
def
finalize(): Unit
-
val
fullStackTrace: String
-
final
def
getClass(): Class[_]
-
final
def
isInstanceOf[T0]: Boolean
-
val
metrics: Option[TaskMetrics]
-
final
def
ne(arg0: AnyRef): Boolean
-
final
def
notify(): Unit
-
final
def
notifyAll(): Unit
-
val
stackTrace: Array[StackTraceElement]
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
-
def
toErrorString: String
-
final
def
wait(): Unit
-
final
def
wait(arg0: Long, arg1: Int): Unit
-
final
def
wait(arg0: Long): Unit
Value Members
-
def
countTowardsTaskFailures: Boolean
Inherited from AnyRef
Value Members
-
final
def
!=(arg0: AnyRef): Boolean
-
final
def
##(): Int
-
final
def
==(arg0: AnyRef): Boolean
-
def
clone(): AnyRef
-
final
def
eq(arg0: AnyRef): Boolean
-
def
finalize(): Unit
-
final
def
getClass(): Class[_]
-
final
def
ne(arg0: AnyRef): Boolean
-
final
def
notify(): Unit
-
final
def
notifyAll(): Unit
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
-
final
def
wait(): Unit
-
final
def
wait(arg0: Long, arg1: Int): Unit
-
final
def
wait(arg0: Long): Unit
Inherited from Any
Value Members
-
final
def
!=(arg0: Any): Boolean
-
final
def
==(arg0: Any): Boolean
-
final
def
asInstanceOf[T0]: T0
-
final
def
isInstanceOf[T0]: Boolean
Ungrouped
-
final
def
!=(arg0: AnyRef): Boolean
-
final
def
!=(arg0: Any): Boolean
-
final
def
##(): Int
-
final
def
==(arg0: AnyRef): Boolean
-
final
def
==(arg0: Any): Boolean
-
final
def
asInstanceOf[T0]: T0
-
val
className: String
-
def
clone(): AnyRef
-
def
countTowardsTaskFailures: Boolean
-
val
description: String
-
final
def
eq(arg0: AnyRef): Boolean
-
def
exception: Option[Throwable]
-
def
finalize(): Unit
-
val
fullStackTrace: String
-
final
def
getClass(): Class[_]
-
final
def
isInstanceOf[T0]: Boolean
-
val
metrics: Option[TaskMetrics]
-
final
def
ne(arg0: AnyRef): Boolean
-
final
def
notify(): Unit
-
final
def
notifyAll(): Unit
-
val
stackTrace: Array[StackTraceElement]
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
-
def
toErrorString: String
-
final
def
wait(): Unit
-
final
def
wait(arg0: Long, arg1: Int): Unit
-
final
def
wait(arg0: Long): Unit
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 usethis(e: Throwable, metrics: Option[TaskMetrics])
to createExceptionFailure
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 causesexception
is the actual exception that caused the task to fail. It may beNone
in the case that the exception is not in fact serializable. If a task fails more than once (due to retries),exception
is that one that caused the last failure.