You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2023/05/25 16:22:13 UTC
[pulsar] branch branch-3.0 updated: [fix][fn] Make pulsar-admin support update py/go with package url (#19897)
This is an automated email from the ASF dual-hosted git repository.
mmarshall 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 b8db81a6b7b [fix][fn] Make pulsar-admin support update py/go with package url (#19897)
b8db81a6b7b is described below
commit b8db81a6b7bc57ea4b2ceeb6fe32fdf7da613c3a
Author: jiangpengcheng <sc...@gmail.com>
AuthorDate: Wed May 10 21:16:17 2023 +0800
[fix][fn] Make pulsar-admin support update py/go with package url (#19897)
(cherry picked from commit fb9c4d034bfdcfdf256720ec2490c737cae53839)
---
.../src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java
index 05bab9c6f19..d951abe0fb2 100644
--- a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java
+++ b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java
@@ -1030,6 +1030,10 @@ public class CmdFunctions extends CmdBase {
updateOptions.setUpdateAuthData(updateAuthData);
if (Utils.isFunctionPackageUrlSupported(functionConfig.getJar())) {
getAdmin().functions().updateFunctionWithUrl(functionConfig, functionConfig.getJar(), updateOptions);
+ } else if (Utils.isFunctionPackageUrlSupported(functionConfig.getPy())) {
+ getAdmin().functions().updateFunctionWithUrl(functionConfig, functionConfig.getPy(), updateOptions);
+ } else if (Utils.isFunctionPackageUrlSupported(functionConfig.getGo())) {
+ getAdmin().functions().updateFunctionWithUrl(functionConfig, functionConfig.getGo(), updateOptions);
} else {
getAdmin().functions().updateFunction(functionConfig, userCodeFile, updateOptions);
}