apache / apache/beam

Failed to run dataflow to consume pubsub

Open
#20,134 0 comments 0 reactions 0 assignees View on GitHub
bug dataflow gcp io java P3 runners
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

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.