You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by je...@apache.org on 2019/01/03 07:53:12 UTC
[pulsar] branch master updated: remove function details from v3
function endpoints (#3271)
This is an automated email from the ASF dual-hosted git repository.
jerrypeng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new a514ec7 remove function details from v3 function endpoints (#3271)
a514ec7 is described below
commit a514ec7525c1190adc2614fec012e3c3f4e03928
Author: Boyang Jerry Peng <je...@gmail.com>
AuthorDate: Wed Jan 2 23:53:07 2019 -0800
remove function details from v3 function endpoints (#3271)
---
.../java/org/apache/pulsar/broker/admin/impl/FunctionsBase.java | 6 ++----
.../pulsar/functions/worker/rest/api/v3/FunctionApiV3Resource.java | 6 ++----
2 files changed, 4 insertions(+), 8 deletions(-)
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/FunctionsBase.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/FunctionsBase.java
index 3d81f83..73af2c5 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/FunctionsBase.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/FunctionsBase.java
@@ -79,11 +79,10 @@ public class FunctionsBase extends AdminResource implements Supplier<WorkerServi
final @FormDataParam("data") InputStream uploadedInputStream,
final @FormDataParam("data") FormDataContentDisposition fileDetail,
final @FormDataParam("url") String functionPkgUrl,
- final @FormDataParam("functionDetails") String functionDetailsJson,
final @FormDataParam("functionConfig") String functionConfigJson) {
functions.registerFunction(tenant, namespace, functionName, uploadedInputStream, fileDetail,
- functionPkgUrl, functionDetailsJson, functionConfigJson, clientAppId());
+ functionPkgUrl, null, functionConfigJson, clientAppId());
}
@PUT
@@ -101,11 +100,10 @@ public class FunctionsBase extends AdminResource implements Supplier<WorkerServi
final @FormDataParam("data") InputStream uploadedInputStream,
final @FormDataParam("data") FormDataContentDisposition fileDetail,
final @FormDataParam("url") String functionPkgUrl,
- final @FormDataParam("functionDetails") String functionDetailsJson,
final @FormDataParam("functionConfig") String functionConfigJson) {
functions.updateFunction(tenant, namespace, functionName, uploadedInputStream, fileDetail,
- functionPkgUrl, functionDetailsJson, functionConfigJson, clientAppId());
+ functionPkgUrl, null, functionConfigJson, clientAppId());
}
diff --git a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v3/FunctionApiV3Resource.java b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v3/FunctionApiV3Resource.java
index d25f8f9..2eebf62 100644
--- a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v3/FunctionApiV3Resource.java
+++ b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v3/FunctionApiV3Resource.java
@@ -66,11 +66,10 @@ public class FunctionApiV3Resource extends FunctionApiResource {
final @FormDataParam("data") InputStream uploadedInputStream,
final @FormDataParam("data") FormDataContentDisposition fileDetail,
final @FormDataParam("url") String functionPkgUrl,
- final @FormDataParam("functionDetails") String functionDetailsJson,
final @FormDataParam("functionConfig") String functionConfigJson) {
functions.registerFunction(tenant, namespace, functionName, uploadedInputStream, fileDetail,
- functionPkgUrl, functionDetailsJson, functionConfigJson, clientAppId());
+ functionPkgUrl, null, functionConfigJson, clientAppId());
}
@@ -83,11 +82,10 @@ public class FunctionApiV3Resource extends FunctionApiResource {
final @FormDataParam("data") InputStream uploadedInputStream,
final @FormDataParam("data") FormDataContentDisposition fileDetail,
final @FormDataParam("url") String functionPkgUrl,
- final @FormDataParam("functionDetails") String functionDetailsJson,
final @FormDataParam("functionConfig") String functionConfigJson) {
functions.updateFunction(tenant, namespace, functionName, uploadedInputStream, fileDetail,
- functionPkgUrl, functionDetailsJson, functionConfigJson, clientAppId());
+ functionPkgUrl, null, functionConfigJson, clientAppId());
}