You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by "Luke Cwik (JIRA)" <ji...@apache.org> on 2017/10/04 23:15:00 UTC

[jira] [Created] (BEAM-3016) BeamFnLoggingClient shutdown stability

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)