infoverload commented on a change in pull request #517: URL: https://github.com/apache/flink-web/pull/517#discussion_r838142903
########## File path: _posts/2022-03-16-async-sink-base.md ########## @@ -0,0 +1,138 @@ +--- +layout: post +title: "Asynchronous Base Sink" +date: 2022-03-17 16:00:00 +authors: +- CrynetLogistics: + name: "Zichen Liu" + twitter: "CrynetLogistics" +excerpt: An overview of the new features of the new Async Base Sink and pointers for building your own concrete sink atop +--- + +The basic functionalities of sinks in general are quite similar. They batch records according to user defined buffering hints, sign requests, write them to the destination, retry unsuccessful or throttled requests, and participate in checkpointing. + +New for [Flink 1.15](https://cwiki.apache.org/confluence/display/FLINK/FLIP-171%3A+Async+Sink) is the Async Base Sink - an abstract sink with a number of common functionalities extracted. Adding support for a new destination now only requires a lightweight shim that implements the specific interfaces of the destination using a client that supports async requests. Review comment: ```suggestion New in [Flink 1.15](https://cwiki.apache.org/confluence/display/FLINK/FLIP-171%3A+Async+Sink) is the AsyncBaseSink, an abstract sink with a number of common functionalities extracted. Adding support for a new destination now only requires a lightweight shim that implements the specific interfaces of the destination using a client that supports async requests. ``` -- 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]
