dannycranmer commented on pull request #18880: URL: https://github.com/apache/flink/pull/18880#issuecomment-1048845280
I discussed this with @fapaul and we agreed that we can merge this change as a bug fix if we do not modify any public API. Therefore instead of adding the rate limiter to the concrete KDF/KDS implementation we will add it directly to the `AsyncSinkWriter`. We will follow up in Flink 1.16 with a FLIP to consolidate the feature and refactor at this point. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
