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 a19d6365415b4a112c30b82e711fbf2877716515
Author: Sanjeev Kulkarni <sanj...@streaml.io>
AuthorDate: Tue Oct 9 11:52:30 2018 -0700

    More compile fixes
---
 .../src/main/java/org/apache/pulsar/broker/admin/impl/SinkBase.java     | 2 +-
 .../src/main/java/org/apache/pulsar/broker/admin/impl/SourceBase.java   | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/SinkBase.java 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/SinkBase.java
index 43ca8bf..2fe3989 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/SinkBase.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/SinkBase.java
@@ -164,7 +164,7 @@ public class SinkBase extends AdminResource implements 
Supplier<WorkerService> {
     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-broker/src/main/java/org/apache/pulsar/broker/admin/impl/SourceBase.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/SourceBase.java
index b4428ab..1a82ac2 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/SourceBase.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/SourceBase.java
@@ -166,7 +166,7 @@ public class SourceBase extends AdminResource implements 
Supplier<WorkerService>
     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

Reply via email to