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 0498a17 [BEAM-11413] Fix default job server for Spark tests.
new 7b39702 Merge pull request #13498 from ibzib/BEAM-11413
0498a17 is described below
commit 0498a17f723efda0f4e6884fbbf471b64fabd8b5
Author: Kyle Weaver <[email protected]>
AuthorDate: Mon Dec 7 13:52:19 2020 -0800
[BEAM-11413] Fix default job server for Spark tests.
---
sdks/python/apache_beam/runners/portability/spark_runner_test.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 7898618..1b873cf 100644
--- a/sdks/python/apache_beam/runners/portability/spark_runner_test.py
+++ b/sdks/python/apache_beam/runners/portability/spark_runner_test.py
@@ -87,7 +87,7 @@ class
SparkRunnerTest(portable_runner_test.PortableRunnerTest):
self.set_spark_job_server_jar(
known_args.spark_job_server_jar or
job_server.JavaJarJobServer.path_to_beam_jar(
- ':runners:job-server:shadowJar'))
+ ':runners:spark:job-server:shadowJar'))
self.environment_type = known_args.environment_type
self.environment_options = known_args.environment_options
