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