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

[EFO][backport] Add timeout when waiting for subscription and delivering data to prevent lockup #31

Closed dannycranmer closed 3 years ago

dannycranmer commented 3 years ago

Description of changes:

This is a backport of https://github.com/awslabs/amazon-kinesis-connector-flink/pull/18

Add timeout when:

If timeout fires the EFO source will cancel subscription, backoff and retry. This change is intended to prevent deadlocks from occurring.

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