[pulsar] 02/04: Fix bugs after mergin

[sanjeevrk]

This is an automated email from the ASF dual-hosted git repository.

sanjeevrk pushed a commit to branch srkukarni/serverside_validation_endpoints
in repository https://gitbox.apache.org/repos/asf/pulsar.git

commit 6915ff80c1cde193a6f4b1804e6351b920bd2e00
Author: Sanjeev Kulkarni <sanj...@streaml.io>
AuthorDate: Tue Oct 9 11:49:24 2018 -0700

    Fix bugs after mergin
---
 .../apache/pulsar/functions/worker/rest/api/v2/SinkApiV2Resource.java   | 2 +-
 .../apache/pulsar/functions/worker/rest/api/v2/SourceApiV2Resource.java | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v2/SinkApiV2Resource.java
 
b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v2/SinkApiV2Resource.java
index e36b069..65d7a1a 100644
--- 
a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v2/SinkApiV2Resource.java
+++ 
b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v2/SinkApiV2Resource.java
@@ -104,7 +104,7 @@ public class SinkApiV2Resource extends FunctionApiResource {
     public Response getSinkStatus(final @PathParam("tenant") String tenant,
                                   final @PathParam("namespace") String 
namespace,
                                   final @PathParam("sinkName") String 
sinkName) throws IOException {
-        return functions.getFunctionStatus(tenant, namespace, sinkName);
+        return functions.getFunctionStatus(tenant, namespace, sinkName, 
uri.getRequestUri());
     }
 
     @GET
diff --git 
a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v2/SourceApiV2Resource.java
 
b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v2/SourceApiV2Resource.java
index cfb6baa..44fac19 100644
--- 
a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v2/SourceApiV2Resource.java
+++ 
b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v2/SourceApiV2Resource.java
@@ -104,7 +104,7 @@ public class SourceApiV2Resource extends 
FunctionApiResource {
     public Response getSourceStatus(final @PathParam("tenant") String tenant,
                                     final @PathParam("namespace") String 
namespace,
                                     final @PathParam("sourceName") String 
sourceName) throws IOException {
-        return functions.getFunctionStatus(tenant, namespace, sourceName);
+        return functions.getFunctionStatus(tenant, namespace, sourceName, 
uri.getRequestUri());
     }
 
     @GET