You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ib...@apache.org on 2020/12/08 18:32:11 UTC
[beam] branch master updated: [BEAM-11413] Fix default job server
for Spark tests.
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 <kc...@google.com>
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