awslabs / amazon-kinesis-connector-flink

This is a fork of the Apache Flink Kinesis connector adding Enhanced Fanout support for Flink 1.8/1.11 on KDA.
Apache License 2.0
20 stars 11 forks source link

Treating TimeoutException as Recoverable #28

Closed dannycranmer closed 3 years ago

dannycranmer commented 3 years ago

Issue #, if available: https://github.com/awslabs/amazon-kinesis-connector-flink/issues/21

Description of changes: Handle TimeoutException using the same mechanism as Netty ReadTimeoutException.

By submitting this pull request, I confirm that you can use, modify, copy, and redistribute this contribution, under the terms of your choice.