org.apache.flink.runtime.operators.chaining

Class ExceptionInChainedStubException

java.lang.Object

java.lang.Throwable

java.lang.Exception

java.lang.RuntimeException

org.apache.flink.runtime.operators.chaining.ExceptionInChainedStubException

All Implemented Interfaces:

Serializable

public class ExceptionInChainedStubException
extends RuntimeException

A special exception to indicate that an exception occurred in the nested call of a chained stub. The exception's only purpose is to be identifiable as such and to carry the cause exception.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ExceptionInChainedStubException(String taskName, Exception wrappedException)

Method Summary

Modifier and Type	Method and Description
static Exception	exceptionUnwrap(Exception e)
String	getTaskName()
Exception	getWrappedException()

Methods inherited from class java.lang.Throwable

addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

ExceptionInChainedStubException

public ExceptionInChainedStubException(String taskName,
                                       Exception wrappedException)

Method Detail

getTaskName

public String getTaskName()

getWrappedException

public Exception getWrappedException()

exceptionUnwrap

public static Exception exceptionUnwrap(Exception e)