[
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:
- // TODO
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:
> - // TODO
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
