pulsar-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jerryp...@apache.org
Subject [pulsar] branch master updated: remove function details from v3 function endpoints (#3271)
Date Thu, 03 Jan 2019 07:53:12 GMT
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 <jerry.boyang.peng@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());
 
     }
 


Mime
View raw message