feast-dev
diff --git a/‎sdk/python/feast/pyspark/launchers/aws/emr_utils.py‎
Lines changed: 6 additions & 4 deletions b/‎sdk/python/feast/pyspark/launchers/aws/emr_utils.py‎
Lines changed: 6 additions & 4 deletions
diff --git a/‎sdk/python/feast/pyspark/launchers/k8s/k8s.py‎
Lines changed: 1 addition & 1 deletion b/‎sdk/python/feast/pyspark/launchers/k8s/k8s.py‎
Lines changed: 1 addition & 1 deletion
@@ -80,12 +80,14 @@ def _random_string(length) -> str:
     return "".join(random.choice(string.ascii_lowercase) for _ in range(length))
 
 
-def _upload_jar(jar_s3_prefix: str, local_path: str) -> str:
-    with open(local_path, "rb") as f:
-        uri = urlparse(os.path.join(jar_s3_prefix, os.path.basename(local_path)))
+def _upload_jar(jar_s3_prefix: str, jar_path: str) -> str:
+    if jar_path.startswith("https://"):
+        return jar_path
+    with open(jar_path, "rb") as f:
+        uri = urlparse(os.path.join(jar_s3_prefix, os.path.basename(jar_path)))
         return urlunparse(
             get_staging_client(uri.scheme).upload_fileobj(
-                f, local_path, remote_uri=uri,
+                f, jar_path, remote_uri=uri,
             )
         )
 
 
@@ -276,7 +276,7 @@ def historical_feature_retrieval(
         return cast(RetrievalJob, self._job_from_job_info(job_info))
 
     def _upload_jar(self, jar_path: str) -> str:
-        if jar_path.startswith("s3://") or jar_path.startswith("s3a://"):
+        if jar_path.startswith("s3://") or jar_path.startswith("s3a://") or jar_path.startswith("https://"):
             return jar_path
         elif jar_path.startswith("file://"):
             local_jar_path = urlparse(jar_path).path