[BEAM-9672] Failed to run dataflow to consume pubsub

• Type: Bug
• Status: Open
• Priority: P3
• Resolution: Unresolved
• Component/s: io-java-gcp, runner-dataflow
• Labels: apache-beam beam dataflow
• Flags: Patch, Important
• Assignee: Unassigned
• Reporter: Adrian Eka Sanjaya
• Created: 02/Apr/20 13:30
• Updated: 04/Jun/22 15:30

Description

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 

{ 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"  }