Package org.apache.flink.cdc.common.exceptions

Class SchemaEvolveException

java.lang.Object

java.lang.Throwable

java.lang.Exception

java.lang.RuntimeException

org.apache.flink.util.FlinkRuntimeException

org.apache.flink.cdc.common.exceptions.SchemaEvolveException

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

UnsupportedSchemaChangeEventException

public class SchemaEvolveException
extends org.apache.flink.util.FlinkRuntimeException

An exception occurred during schema evolution.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected SchemaChangeEvent	applyingEvent
protected Throwable	cause
protected String	exceptionMessage

Constructor Summary

Constructors

Constructor	Description
SchemaEvolveException(SchemaChangeEvent applyingEvent, String exceptionMessage)
SchemaEvolveException(SchemaChangeEvent applyingEvent, String exceptionMessage, Throwable cause)

Method Summary

Modifier and Type	Method	Description
SchemaChangeEvent	getApplyingEvent()
Throwable	getCause()
String	getExceptionMessage()
String	toString()

Methods inherited from class java.lang.Throwable

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

Methods inherited from class java.lang.Object

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

Field Detail

applyingEvent

protected final SchemaChangeEvent applyingEvent

exceptionMessage

protected final String exceptionMessage

cause

@Nullable
protected final Throwable cause

Constructor Detail

SchemaEvolveException

public SchemaEvolveException(SchemaChangeEvent applyingEvent,
                             String exceptionMessage)

SchemaEvolveException

public SchemaEvolveException(SchemaChangeEvent applyingEvent,
                             String exceptionMessage,
                             @Nullable
                             Throwable cause)

Method Detail

getApplyingEvent

public SchemaChangeEvent getApplyingEvent()

getExceptionMessage

public String getExceptionMessage()

getCause

@Nullable
public Throwable getCause()

Overrides:

getCause in class Throwable

toString

public String toString()

Overrides:

toString in class Throwable