pulsar-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sanjee...@apache.org
Subject [pulsar] 02/04: Fix bugs after mergin
Date Tue, 09 Oct 2018 19:33:13 GMT
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 <sanjeev@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


Mime
View raw message