apache/beam

Set region when BigqueryIO.write using DirectRunner

Open

#18,812 建立於 2022年6月3日

在 GitHub 查看
 (0 留言) (0 反應) (0 負責人)Java (4,097 fork)batch import
P3dataflowdirectgood first issuenew featurerunners

倉庫指標

Star
 (7,313 star)
PR 合併指標
 (平均合併 6天) (30 天內合併 243 個 PR)

描述

Cannot set region for BigQuery dataset when using direct runner using Apache Beam. I'm trying to get data from Oracle via JdbcIO.read using apache beam to get data and push them to bigquery table. Problem is I have to use direct runner because Oracle DB is local, and the bigquery dataset must located in asia, not the default us-central. so now I cannot push data because the default location dont have my target dataset. I tried extending the GcpOption but no help. Don't suggest me to use the DataflowRunner, because it cannot load data from Oracle local. Thanks.

Imported from Jira BEAM-4247. Original Jira may contain additional context. Reported by: doduythao.

貢獻者指南