org.apache.flink.streaming.connectors.kinesis

Class FlinkKinesisException.FlinkKinesisTimeoutException

java.lang.Object

java.lang.Throwable

java.lang.Exception

java.lang.RuntimeException

org.apache.flink.streaming.connectors.kinesis.FlinkKinesisException

org.apache.flink.streaming.connectors.kinesis.FlinkKinesisException.FlinkKinesisTimeoutException

All Implemented Interfaces:

Serializable

Enclosing class:

FlinkKinesisException

@Internal
public static class FlinkKinesisException.FlinkKinesisTimeoutException
extends FlinkKinesisException

A semantic RuntimeException thrown to indicate timeout errors in the Kinesis connector.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisException

FlinkKinesisException.FlinkKinesisTimeoutException

Constructor Summary

Constructors

Constructor and Description
FlinkKinesisTimeoutException(String message)

Method Summary

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

FlinkKinesisTimeoutException

public FlinkKinesisTimeoutException(String message)