Update docker image for k8s launcher

khorshuheng · khorshuheng · commit 5d80975edadd · 2021-01-07T13:15:06.000+08:00
Signed-off-by: Khor Shu Heng &lt;khor.heng@gojek.com&gt;
diff --git a/sdk/python/feast/pyspark/launchers/k8s/k8s.py b/sdk/python/feast/pyspark/launchers/k8s/k8s.py
@@ -218,7 +218,7 @@ def historical_feature_retrieval(
             job_type=HISTORICAL_RETRIEVAL_JOB_TYPE,
             main_application_file=pyspark_script_path,
             main_class=None,
-            packages=job_params.get_extra_packages(),
+            packages=[],
             jars=[],
             extra_metadata={METADATA_OUTPUT_URI: job_params.get_destination_path()},
             arguments=job_params.get_arguments(),
diff --git a/sdk/python/feast/pyspark/launchers/k8s/k8s_utils.py b/sdk/python/feast/pyspark/launchers/k8s/k8s_utils.py
@@ -256,7 +256,7 @@ def _cancel_job_by_id(api: CustomObjectsApi, namespace: str, job_id: str):
 spec:
   type: Scala
   mode: cluster
-  image: "gcr.io/kf-feast/spark-py:v3.0.1"
+  image: "gcr.io/kf-feast/spark-py-extra:v3.0.1"
   imagePullPolicy: Always
   sparkVersion: "3.0.1"
   timeToLiveSeconds: 3600
