lukecwik commented on issue #21007: URL: https://github.com/apache/beam/issues/21007#issuecomment-1401030701
The migration to the BeamFnDataGrpcMultiplexer2 in https://github.com/apache/beam/pull/25104 would need to be updated to ensure that when we close the multiplexer that we mark the receiver as failed allowing us to stop leaking BeamFnDataGrpcMultiplexer2 instances instead of relying on the current flow which is the receiver throws an exception during accept() allowing the BeamFnDataClient to unregister the receiver and add the id to the list of known bad instruction ids. -- 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]
