rkhachatryan commented on PR #26888: URL: https://github.com/apache/flink/pull/26888#issuecomment-3173820999
Originally, I fixed the issue in Flink 1.19 by replacing List with Iterator. While porting the fix to 2.0, I discovered that most of the code was extracted to be re-used in async versions of the operators. However, without some deeper rework, I don't see how my change can be used in async way; because async iterator requires callbacks to be passed in. So I'm inclined to have two different versions for sync (iterator) and async (list) for now. WDYT @xuyangzhong, @pnowojski ? -- 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]
