[ https://issues.apache.org/jira/browse/BEAM-5253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16610861#comment-16610861 ]
Henning Rohde commented on BEAM-5253: ------------------------------------- "go run" is expected to work. Would you mind trying to make IsWorkerCompatibleBinary always return false here: https://github.com/apache/beam/blob/609a42978405173a60e5d91f35170a5c0b5d5332/sdks/go/pkg/beam/runners/universal/runnerlib/compile.go#L37 If that works it's a quick workaround. But we need to see if we can do a better check here (such as looking up the symbol table or similar). > 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: Robert Burke > Priority: Critical > Fix For: Not applicable > > Time Spent: 50m > Remaining Estimate: 0h > > 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)