This is an automated email from the ASF dual-hosted git repository.
ibzib 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 15bd9ae Update the test invocation cmd for poratble runner.
new 2a16dd1 Merge pull request #13019 from boyuanzz/cmd_fix
15bd9ae is described below
commit 15bd9ae45874c5e32795e39f07679027dd1bd21e
Author: Boyuan Zhang <[email protected]>
AuthorDate: Tue Oct 6 11:42:31 2020 -0700
Update the test invocation cmd for poratble runner.
---
sdks/python/apache_beam/runners/portability/flink_runner_test.py | 6 ++----
sdks/python/apache_beam/runners/portability/spark_runner_test.py | 6 ++----
2 files changed, 4 insertions(+), 8 deletions(-)
diff --git a/sdks/python/apache_beam/runners/portability/flink_runner_test.py
b/sdks/python/apache_beam/runners/portability/flink_runner_test.py
index e83adac..584b31c 100644
--- a/sdks/python/apache_beam/runners/portability/flink_runner_test.py
+++ b/sdks/python/apache_beam/runners/portability/flink_runner_test.py
@@ -56,10 +56,8 @@ from apache_beam.transforms.sql import SqlTransform
# Run as
#
-# pytest flink_runner_test.py \
-# [--test_pipeline_options "--flink_job_server_jar=/path/to/job_server.jar
\
-# --environment_type=DOCKER"] \
-# [FlinkRunnerTest.test_method, ...]
+# pytest flink_runner_test.py[::TestClass::test_case] \
+# --test-pipeline-options "--environment_type=LOOPBACK"
_LOGGER = logging.getLogger(__name__)
diff --git a/sdks/python/apache_beam/runners/portability/spark_runner_test.py
b/sdks/python/apache_beam/runners/portability/spark_runner_test.py
index a522aca..53f0fbb 100644
--- a/sdks/python/apache_beam/runners/portability/spark_runner_test.py
+++ b/sdks/python/apache_beam/runners/portability/spark_runner_test.py
@@ -35,10 +35,8 @@ from apache_beam.runners.portability import
portable_runner_test
# Run as
#
-# pytest spark_runner_test.py \
-# [--test_pipeline_options "--spark_job_server_jar=/path/to/job_server.jar
\
-# --environment_type=DOCKER"] \
-# [SparkRunnerTest.test_method, ...]
+# pytest spark_runner_test.py[::TestClass::test_case] \
+# --test-pipeline-options "--environment_type=LOOPBACK"
_LOGGER = logging.getLogger(__name__)