kennknowles opened a new issue, #19183: URL: https://github.com/apache/beam/issues/19183
GrpcStateService by default uses a non-thread-safe OutboundServer which has led to problem with asynchronously sending data to it. The sending is now changed to be done synchronously but it could be done asynchronously if OutboundObserverFactory was used. Depending on the Runner, asynchronicity may or may not be desired. We should provide a way to configure parallelism of GrpcStateService for each Runner. Imported from Jira [BEAM-6166](https://issues.apache.org/jira/browse/BEAM-6166). Original Jira may contain additional context. Reported by: mxm. -- 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]
