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

Posted to commits@beam.apache.org by "Sean Patrick Hagen (JIRA)" <ji...@apache.org> on 2018/08/28 22:52:00 UTC

[jira] [Created] (BEAM-5253) Go SDK PubSub example currently broken

Sean Patrick Hagen created BEAM-5253:
----------------------------------------

             Summary: Go SDK PubSub example currently broken
                 Key: BEAM-5253
                 URL: https://issues.apache.org/jira/browse/BEAM-5253
             Project: Beam
          Issue Type: Bug
          Components: sdk-go
            Reporter: Sean Patrick Hagen
            Assignee: Henning Rohde


The Go SDK contains an example for creating a streaming pipeline that reads from pubsub and outputs the messages. It can be found here: [https://github.com/apache/beam/blob/master/sdks/go/examples/streaming_wordcap/wordcap.go]

 

This example is broken and does not work. It fails with the error "failed to execute job: translation failed: no root units" when I try to run it with the direct runner, and it just fails with "Internal Issue (8ed815a0a259018f): 65177287:8503 " when run in Google Dataflow.

 

 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)