You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by "Henning Rohde (JIRA)" <ji...@apache.org> on 2018/08/31 20:05:00 UTC
[jira] [Commented] (BEAM-5253) Go SDK PubSub example currently
broken
[ https://issues.apache.org/jira/browse/BEAM-5253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16599220#comment-16599220 ]
Henning Rohde commented on BEAM-5253:
-------------------------------------
[~seanhagen]:
(1) The direct runner doesn't support pubsub (or streaming pipelines). So that error is expected, although it could be clearer.
(2) Can you include the command you use on Dataflow? And maybe include a job id? The example works for me.
> 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
> Priority: Critical
>
> 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)