0

According to this and this the problem should be fixed, isn't?

What I'm doing:

| 'Read' >> beam.io.Read(beam.io.BigQuerySource(
                    query='SELECT * FROM XXX.YYY', use_standard_sql=True))

What I get:

Cannot read and write in different locations: source: EU, destination: US

What I've tried:

  • Specified the zone in pipeline_options:

        pipeline_options.view_as(WorkerOptions).zone = 'europe-west1'

  • Use dryRun:

But none of them solved the problem.

EXTRA:

If you use:

| 'Read' >> beam.io.Read(beam.io.BigQuerySource(
                 table='XXX:YYY.Table'))

You can get the result without problem

IoT user
  • 1,222
  • 4
  • 22
  • 49

1 Answers1

0

Fixed updating the google-cloud-bigquery python package

IoT user
  • 1,222
  • 4
  • 22
  • 49