Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-9672

Failed to run dataflow to consume pubsub

    XMLWordPrintableJSON

    Details

    • Flags:
      Patch, Important

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

        Attachments

        1. Screenshot from 2020-04-02 20-42-19.png
          46 kB
          Adrian Eka Sanjaya

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              adrian3ka Adrian Eka Sanjaya
            • Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

              • Created:
                Updated:

                Time Tracking

                Estimated:
                Original Estimate - 24h
                24h
                Remaining:
                Remaining Estimate - 24h
                24h
                Logged:
                Time Spent - Not Specified
                Not Specified