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__)
 

Reply via email to