Failed to run dataflow to consume pubsub
- Dominant language
- Java
- Stars
- 8.7k
- Forks
- 4.7k
- Avg merge
- 1d 20h
- Merged PRs (30d)
- 196
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" }
```
Imported from Jira [BEAM-9672](https://issues.apache.org/jira/browse/BEAM-9672). Original Jira may contain additional context.
Reported by: adrian3ka.
Contributor guide
Assessment
This issue has not been assessed yet.