Luke Cwik created BEAM-3016:
-------------------------------
Summary: BeamFnLoggingClient shutdown stability
Key: BEAM-3016
URL: https://issues.apache.org/jira/browse/BEAM-3016
Project: Beam
Issue Type: Bug
Components: sdk-java-harness
Reporter: Luke Cwik
Assignee: Luke Cwik
Priority: Minor
The BeamFnLoggingClient has a race condition where it may not shutdown
appropriately if the channel has an error.
This occurs because the stream observer created by the StreamObserverFactory
may block indefinitely if the DirectStreamObserver is used.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)