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 42925ff [BEAM-12095] Fix Spark job server in uber jar path as well. new eb9635f Merge pull request #14435 from ibzib/BEAM-12095 42925ff is described below commit 42925ff7b7c8c00a4e9ecd85c8d45e1e58dfaca9 Author: Kyle Weaver <kcwea...@google.com> AuthorDate: Mon Apr 5 13:58:57 2021 -0700 [BEAM-12095] Fix Spark job server in uber jar path as well. Missed a spot. --- .../apache_beam/runners/portability/spark_uber_jar_job_server.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/sdks/python/apache_beam/runners/portability/spark_uber_jar_job_server.py b/sdks/python/apache_beam/runners/portability/spark_uber_jar_job_server.py index c2d6504..fdd481e 100644 --- a/sdks/python/apache_beam/runners/portability/spark_uber_jar_job_server.py +++ b/sdks/python/apache_beam/runners/portability/spark_uber_jar_job_server.py @@ -77,7 +77,8 @@ class SparkUberJarJobServer(abstract_job_service.AbstractJobServiceServicer): url = self._executable_jar else: url = job_server.JavaJarJobServer.path_to_beam_jar( - ':runners:spark:2:job-server:shadowJar') + ':runners:spark:2:job-server:shadowJar', + artifact_id='beam-runners-spark-job-server') return job_server.JavaJarJobServer.local_jar(url) def create_beam_job(self, job_id, job_name, pipeline, options):