[
https://issues.apache.org/jira/browse/BEAM-8253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211266#comment-17211266
]
Kyle Weaver commented on BEAM-8253:
-----------------------------------
[~jingc] if you want to work on this, I'd be happy to provide help/review :)
1. Add worker_region and worker_zone to flags in
https://github.com/apache/beam/blob/master/sdks/go/pkg/beam/runners/dataflow/dataflow.go
2. Validate their usage (like this:
https://github.com/apache/beam/blob/925e0d86d55ab2276803d1456a4548c96d8bc6ee/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java#L396-L430)
3. Pass worker_region or worker_zone to the Dataflow job's environment:
https://github.com/apache/beam/blob/master/sdks/go/pkg/beam/runners/dataflow/dataflowlib/job.go
> (Go SDK) Add worker_region and worker_zone options
> --------------------------------------------------
>
> Key: BEAM-8253
> URL: https://issues.apache.org/jira/browse/BEAM-8253
> Project: Beam
> Issue Type: Sub-task
> Components: runner-dataflow, sdk-go
> Reporter: Kyle Weaver
> Priority: P3
> Labels: stale-assigned
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
