scwhittle commented on code in PR #40978: URL: https://github.com/apache/beam/pull/40978#discussion_r4478268840
########## sdks/java/core/src/main/java/org/apache/beam/sdk/util/BundleLifter.java: ########## Review Comment: Unrelated so can be done separate PR, but I think that it could be improved to stream the elements through. Once we've exceeded threshold we transition to large output and 1. flush the existing queue 2. stop sizing/queuing further process elements and just outputting them directly. -- 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]
