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

…pache#21955)
datastax · Jan 31, 2024 · d3b7ca5 · d3b7ca5
1 parent a702e5a
commit d3b7ca5
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
@@ -1766,6 +1766,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)) {