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)
