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 <[email protected]>
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());
}