Maximilian Michels created BEAM-6166:
----------------------------------------
Summary: Allow Runners to configure parallelism of GrpcStateService
Key: BEAM-6166
URL: https://issues.apache.org/jira/browse/BEAM-6166
Project: Beam
Issue Type: Improvement
Components: runner-core
Reporter: Maximilian Michels
Assignee: Maximilian Michels
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.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
