This is an automated email from the ASF dual-hosted git repository.
technoboy pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new 9baebfa65f3 [fix][fn] Use unified PackageManagement service to
download packages (#21955)
9baebfa65f3 is described below
commit 9baebfa65f3514981810db70af5ec130bb413643
Author: jiangpengcheng <[email protected]>
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 585b54d8461..6bde2b4fc88 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
@@ -1822,6 +1822,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)) {
