[ https://issues.apache.org/jira/browse/FLINK-25793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17497487#comment-17497487 ]
Danny Cranmer commented on FLINK-25793: --------------------------------------- Merged to master https://github.com/apache/flink/commit/f5335664dff304ece318a34a9cf939656ee3a2e5 > Fix high throughput rate of AsyncSinkWriter for throttled destination > --------------------------------------------------------------------- > > Key: FLINK-25793 > URL: https://issues.apache.org/jira/browse/FLINK-25793 > Project: Flink > Issue Type: Bug > Components: Connectors / Kinesis > Reporter: Zichen Liu > Assignee: Ahmed Hamdy > Priority: Major > Labels: pull-request-available > Fix For: 1.15.0 > > > h2. Bug: > The Async Sink Base sink is not limiting throughput to the destination and > therefore exceeding rate limits > *Cause:* > We are not throttling our requests downstream at all. > We should monitor for requests that have failed with ThroughputExceeded > exceptions and reduce the throughput accordingly. -- This message was sent by Atlassian Jira (v8.20.1#820001)