robertwb commented on issue #11173: [BEAM-9558] Add explicit end bit for data channel. URL: https://github.com/apache/beam/pull/11173#issuecomment-601858195 So I spent quite a bit of time refactoring things to do the separate "end all streams for this bundle" proposal that we discussed, and it turns out that gets quite messy. (One of the things that makes this less nice is, as things stand, there may be multiple data stream endpoints for a single bundle. The need to preserve ordering between the data and end markers across threads other than those handling the grpc request, and the fact that buffering streams need to flush so closing them all needs to happen anyway, reduces the potential wins.) Combined with the fact that it gets even uglier to try to support both modes simultaneously during any transition period, I'm just going to go for this simpler, original fix for now.
---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
