(pulsar) branch branch-3.2 updated: [fix][fn] Use unified PackageManagement service to download packages (#21955)

[technoboy]

This is an automated email from the ASF dual-hosted git repository.

technoboy pushed a commit to branch branch-3.2
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-3.2 by this push:
     new c980ee24b72 [fix][fn] Use unified PackageManagement service to 
download packages (#21955)
c980ee24b72 is described below

commit c980ee24b726bcf6f6f980a60d94ce37d8e73016
Author: jiangpengcheng <scjiangpengch...@gmail.com>
AuthorDate: Wed Jan 31 22:18:47 2024 +0800

    [fix][fn] Use unified PackageManagement service to download packages 
(#21955)
---
 .../java/org/apache/pulsar/functions/worker/rest/api/ComponentImpl.java | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/ComponentImpl.java
 
b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/ComponentImpl.java
index db31847f91c..fc2873d8271 100644
--- 
a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/ComponentImpl.java
+++ 
b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/ComponentImpl.java
@@ -1766,6 +1766,8 @@ public abstract class ComponentImpl implements 
Component<PulsarWorkerService> {
                                 + "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)) {