org.apache.flink.runtime.util

Class ClusterUncaughtExceptionHandler

java.lang.Object

org.apache.flink.runtime.util.ClusterUncaughtExceptionHandler

All Implemented Interfaces:

Thread.UncaughtExceptionHandler

public class ClusterUncaughtExceptionHandler
extends Object
implements Thread.UncaughtExceptionHandler

Utility for handling any uncaught exceptions

Handles any uncaught exceptions according to cluster configuration in ClusterOptions to either just log exception, or fail job.

Constructor Summary

Constructors

Constructor and Description
ClusterUncaughtExceptionHandler(ClusterOptions.UncaughtExceptionHandleMode handleMode)

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

Constructor Detail

ClusterUncaughtExceptionHandler

public ClusterUncaughtExceptionHandler(ClusterOptions.UncaughtExceptionHandleMode handleMode)

Method Detail

uncaughtException

public void uncaughtException(Thread t,
                              Throwable e)

Specified by:

uncaughtException in interface Thread.UncaughtExceptionHandler