[beam] branch master updated: [BEAM-12095] Fix Spark job server in uber jar path as well.

[ib...@apache.org]

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 <kc...@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):