rkhachatryan commented on PR #26888: URL: https://github.com/apache/flink/pull/26888#issuecomment-3306560049
> 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 ? We've discussed this offline with @pnowojski and @Zakelly and decided to have separate versions of the code for now but create a ticket for the async version: https://issues.apache.org/jira/browse/FLINK-38376 -- 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]
