Allow Runners to configure parallelism of GrpcStateService
Open
core
improvement
P3
runners
- Dominant language
- Java
- Stars
- 8.7k
- Forks
- 4.7k
- Avg merge
- 1d 20h
- Merged PRs (30d)
- 196
Description
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.
Contributor guide
Assessment
This issue has not been assessed yet.