org.apache.spark.util

Class SparkUncaughtExceptionHandler

Object

org.apache.spark.util.SparkUncaughtExceptionHandler

All Implemented Interfaces:

Thread.UncaughtExceptionHandler, Logging

public class SparkUncaughtExceptionHandler
extends Object
implements Thread.UncaughtExceptionHandler, Logging

The default uncaught exception handler for Executors terminates the whole process, to avoid getting into a bad state indefinitely. Since Executors are relatively lightweight, it's better to fail fast when things go wrong.

Constructor Summary

Constructors

Constructor and Description
SparkUncaughtExceptionHandler()

Method Summary

Methods

Modifier and Type	Method and Description
static void	uncaughtException(Thread thread, Throwable exception)
static void	uncaughtException(Throwable exception)

Methods inherited from class Object

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

Methods inherited from interface Thread.UncaughtExceptionHandler

uncaughtException

Methods inherited from interface org.apache.spark.Logging

initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning

Constructor Detail

SparkUncaughtExceptionHandler

public SparkUncaughtExceptionHandler()

Method Detail

uncaughtException

public static void uncaughtException(Thread thread,
                     Throwable exception)

uncaughtException

public static void uncaughtException(Throwable exception)