Description
Setting the `worker_harness_container_image` flag to a custom built worker doesn't seem to have any impact when launching on dataflow. The default apache/beam_go_sdk:latest image is always used.
$ go run sdks/go/examples/wordcount/wordcount.go --output=gs://.../tmp/out.txt --project=... --runner=dataflow --region=us-central1 --temp_location gs://.../tmp --staging_location gs://.../staging --worker_harness_container_image=fake/image:latest 2020/08/19 22:56:28 WARNING: proto: file "v1.proto" is already registered 2020/08/19 22:56:28 No environment config specified. Using default config: 'apache/beam_go_sdk:latest'
Attachments
Issue Links
- links to