This is an automated email from the ASF dual-hosted git repository.
altay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new ab2e94d Add use_unified_worker to pipeline options.
new ae1df91 Merge pull request #13396 from boyuanzz/taxi_cmd
ab2e94d is described below
commit ab2e94d3b903c436fd012a02d5b4d5ab6f037814
Author: Boyuan Zhang <[email protected]>
AuthorDate: Fri Nov 20 11:53:47 2020 -0800
Add use_unified_worker to pipeline options.
---
sdks/python/apache_beam/examples/kafkataxi/README.md | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/sdks/python/apache_beam/examples/kafkataxi/README.md
b/sdks/python/apache_beam/examples/kafkataxi/README.md
index e8e144d..674dbd8 100644
--- a/sdks/python/apache_beam/examples/kafkataxi/README.md
+++ b/sdks/python/apache_beam/examples/kafkataxi/README.md
@@ -185,5 +185,7 @@ python -m apache_beam.examples.kafkataxi.kafka_taxi \
--job_name $JOB_NAME \
--bootstrap_servers $BOOTSTRAP_SERVER \
--sdk_harness_container_image_overrides
".*java.*,${DOCKER_ROOT}/beam_java8_sdk:latest" \
- --experiments=use_runner_v2
+ --experiments=use_runner_v2 \
+ --experiments=use_unified_worker \
+ --experiments=beam_fn_api
```
