[
https://issues.apache.org/jira/browse/FLINK-22479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-22479:
--------------------------------
Fix Version/s: 1.13.1
> [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.14.0, 1.13.1, 1.12.4
>
>
> *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)
