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)

Reply via email to