Sam Whittle created BEAM-12203:
----------------------------------
Summary: Remove LinkedBlockingQueue from BeamFnControlClient
Key: BEAM-12203
URL: https://issues.apache.org/jira/browse/BEAM-12203
Project: Beam
Issue Type: Bug
Components: sdk-java-harness
Reporter: Sam Whittle
Assignee: Sam Whittle
This class has a grpc observer that queues recieved messages on a
LinkedBlockingQueue and then has a separate thread pulling from the the queue
to add to an executor.
Instead we could just add directly to the executor from the grpc stream, as the
executor by default has an unbounded queue size (and there are comments
indicating that a limited size executor can cause deadlocks otherwise)
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
