[
https://issues.apache.org/jira/browse/FLINK-22479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-22479:
----------------------------------
Description:
*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])
was:
*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:
- // TODO
> [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
> Fix For: 1.13.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)
