org.apache.flink.runtime.util

Class FatalExitExceptionHandler

java.lang.Object

org.apache.flink.runtime.util.FatalExitExceptionHandler

All Implemented Interfaces:

Thread.UncaughtExceptionHandler

public final class FatalExitExceptionHandler
extends Object
implements Thread.UncaughtExceptionHandler

Handler for uncaught exceptions that will log the exception and kill the process afterwards.

This guarantees that critical exceptions are not accidentally lost and leave the system running in an inconsistent state.

Field Summary

Fields

Modifier and Type	Field and Description
static FatalExitExceptionHandler	INSTANCE

Constructor Summary

Constructors

Constructor and Description
FatalExitExceptionHandler()

Method Summary

Modifier and Type	Method and Description
void	uncaughtException(Thread t, Throwable e)

Methods inherited from class java.lang.Object

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

Field Detail

INSTANCE

public static final FatalExitExceptionHandler INSTANCE

Constructor Detail

FatalExitExceptionHandler

public FatalExitExceptionHandler()

Method Detail

uncaughtException

public void uncaughtException(Thread t,
                              Throwable e)

Specified by:

uncaughtException in interface Thread.UncaughtExceptionHandler