Danny Cranmer created FLINK-22479:
-------------------------------------
Summary: [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.2, 1.12.1, 1.12.0
Reporter: Danny Cranmer
Assignee: Danny Cranmer
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)