[
https://issues.apache.org/jira/browse/BEAM-9672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17548502#comment-17548502
]
Danny McCormick commented on BEAM-9672:
---------------------------------------
This issue has been migrated to https://github.com/apache/beam/issues/20134
> Failed to run dataflow to consume pubsub
> ----------------------------------------
>
> Key: BEAM-9672
> URL: https://issues.apache.org/jira/browse/BEAM-9672
> Project: Beam
> Issue Type: Bug
> Components: io-java-gcp, runner-dataflow
> Reporter: Adrian Eka Sanjaya
> Priority: P3
> Labels: apache-beam, beam, dataflow
> Attachments: Screenshot from 2020-04-02 20-42-19.png
>
> Original Estimate: 24h
> Remaining Estimate: 24h
>
> I try to run the example on golang streaming_wordcap.go on dataflow
>
> but on worker logs always gets this error on :
>
> Invalid bundle desc: no root units
> In log viewer got this json
> {code:java}
> { insertId: "4443678406175380376:29607:0:37911" jsonPayload: { job:
> "2020-04-02_06_49_21-8976320782752051209" logger:
> "/home/cermati/work/src/github.com/apache/beam/sdks/go/pkg/beam/core/runtime/harness/harness.go:76"
> message: "RESP: instruction_id: "-103"
> error: "Invalid bundle desc: no root units"
> register: <
> >
> " portability_worker_id: "1" worker:
> "go-job-1-1585835270681453-04020649-wgxo-harness-vjpx" } labels: {
> compute.googleapis.com/resource_id: "4443678406175380376"
> compute.googleapis.com/resource_name:
> "go-job-1-1585835270681453-04020649-wgxo-harness-vjpx"
> compute.googleapis.com/resource_type: "instance"
> dataflow.googleapis.com/job_id: "2020-04-02_06_49_21-8976320782752051209"
> dataflow.googleapis.com/job_name: "go-job-1-1585835270681453657"
> dataflow.googleapis.com/region: "us-east1" } logName:
> "projects/beam-tutorial-272917/logs/dataflow.googleapis.com%2Fworker"
> receiveTimestamp: "2020-04-02T13:51:29.833259066Z" resource: { labels: {
> job_id: "2020-04-02_06_49_21-8976320782752051209" job_name:
> "go-job-1-1585835270681453657" project_id: "beam-tutorial-272917"
> region: "us-east1" step_id: "" } type: "dataflow_step" }
> severity: "DEBUG" timestamp: "2020-04-02T13:51:15.671250878Z" }
> {code}
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
