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

Class UnsupportedSchemaChangeEventException

java.lang.Object

java.lang.Throwable

java.lang.Exception

java.lang.RuntimeException

org.apache.flink.util.FlinkRuntimeException

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

org.apache.flink.cdc.common.exceptions.UnsupportedSchemaChangeEventException

All Implemented Interfaces:

Serializable

public class UnsupportedSchemaChangeEventException
extends SchemaEvolveException

A special kind of SchemaEvolveException that sink doesn't support such event type.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.flink.cdc.common.exceptions.SchemaEvolveException

applyingEvent, cause, exceptionMessage

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
String	toString()

Methods inherited from class org.apache.flink.cdc.common.exceptions.SchemaEvolveException

getApplyingEvent, getCause, getExceptionMessage

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

Constructor Detail

UnsupportedSchemaChangeEventException

public UnsupportedSchemaChangeEventException(SchemaChangeEvent applyingEvent)

UnsupportedSchemaChangeEventException

public UnsupportedSchemaChangeEventException(SchemaChangeEvent applyingEvent,
                                             String exceptionMessage)

UnsupportedSchemaChangeEventException

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

Method Detail

toString

public String toString()

Overrides:

toString in class SchemaEvolveException