[ https://issues.apache.org/jira/browse/FLINK-25793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Zichen Liu updated FLINK-25793: ------------------------------- Summary: Fix high throughput rate of AsyncSinkWriter for throttled destination (was: Introduce rate limiting mechanism to Async Sink Base) > 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)