[fix][fn] Use unified PackageManagement service to download packages (#…

…21955)
apache · Feb 5, 2024 · 9baebfa · 9baebfa
1 parent 9076951
commit 9baebfa
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...tions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/ComponentImpl.java b/...tions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/ComponentImpl.java
@@ -1822,6 +1822,8 @@ protected File getPackageFile(String functionPkgUrl, String existingPackagePath,
                                 + "when getting %s package from %s", e.getMessage(),
                         ComponentTypeUtils.toString(componentType), functionPkgUrl));
             }
+        } else if (Utils.hasPackageTypePrefix(existingPackagePath)) {
+            componentPackageFile = getPackageFile(existingPackagePath);
         } else if (uploadedInputStream != null) {
             componentPackageFile = WorkerUtils.dumpToTmpFile(uploadedInputStream);
         } else if (!existingPackagePath.startsWith(Utils.BUILTIN)) {