Zakelly commented on PR #24690: URL: https://github.com/apache/flink/pull/24690#issuecomment-2071298219
> Hi @Zakelly, the code si LGTM, I have one question, why didn't leverage the capability of Reactor for these kind of async callback? It seems very similar to me, anything I missed? just curious. Do you mean the Project Reactor? The main reason is that we want to carefully customize and control the processing of async requests, to make sure it correctly interacts with Flink's components (back-pressure, mailbox, watermark and checkpoint). So what we really need is the basic functionality of futures, and we built up the whole async processing on top of this. -- 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]
