Согласно это и это проблема должна быть решена, не так ли?
Что я делаю:
| 'Read' >> beam.io.Read(beam.io.BigQuerySource(
query='SELECT * FROM XXX.YYY', use_standard_sql=True))
Что я получаю:
Cannot read and write in different locations: source: EU, destination: US
Что я пробовал:
Но ни один из них не решил проблему.
ДОПОЛНИТЕЛЬНО:
Если вы используете:
| 'Read' >> beam.io.Read(beam.io.BigQuerySource(
table='XXX:YYY.Table'))
Вы можете получить результат без проблем