[ https://issues.apache.org/jira/browse/FLINK-22479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
ASF GitHub Bot updated FLINK-22479: ----------------------------------- Labels: pull-request-available (was: ) > [Kinesis][Consumer] Potential lock-up under error condition > ----------------------------------------------------------- > > Key: FLINK-22479 > URL: https://issues.apache.org/jira/browse/FLINK-22479 > Project: Flink > Issue Type: Bug > Components: Connectors / Kinesis > Affects Versions: 1.12.0, 1.12.1, 1.12.2 > Reporter: Danny Cranmer > Assignee: Danny Cranmer > Priority: Critical > Labels: pull-request-available > Fix For: 1.13.0, 1.14.0, 1.12.3 > > > *Background* > This connector has been > [forked|https://github.com/awslabs/amazon-kinesis-connector-flink] by AWS for > use on KDA with Flink 1.11. Bugs have been encountered: > - Under high backpressure scenarios > - When an error is thrown during tear down > *Scope* > Pull in the following fixes from AWS fork: > * Fix issue where {{KinesisDataFetcher.shutdownFetcher()}} hangs > ([issue|https://github.com/awslabs/amazon-kinesis-connector-flink/issues/23], > [pull > request|https://github.com/awslabs/amazon-kinesis-connector-flink/pull/24]) > > * Log error when shutting down Kinesis Data Fetcher > ([issue|https://github.com/awslabs/amazon-kinesis-connector-flink/issues/22], > [pull > request|https://github.com/awslabs/amazon-kinesis-connector-flink/pull/25]) > > * Treating TimeoutException as Recoverable Exception > ([issue|https://github.com/awslabs/amazon-kinesis-connector-flink/pull/28], > [pull > request|https://github.com/awslabs/amazon-kinesis-connector-flink/issues/21]) > > * Add time-out for acquiring subscription and passing events from network to > source thread to prevent deadlock ([pull > request|https://github.com/awslabs/amazon-kinesis-connector-flink/pull/18]) -- This message was sent by Atlassian Jira (v8.3.4#803005)