[pulsar] branch master updated: Fix swagger annotations for builtin sources/sinks rest api (#7009)

[sijie]

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

sijie 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 e298ccc  Fix swagger annotations for builtin sources/sinks rest api 
(#7009)
e298ccc is described below

commit e298ccc55143a2dca8bf7b5cae5edbf84bfbd54d
Author: Sanjeev Kulkarni <sanjee...@gmail.com>
AuthorDate: Fri May 22 09:57:18 2020 -0700

    Fix swagger annotations for builtin sources/sinks rest api (#7009)
    
    Co-authored-by: Sanjeev Kulkarni <sanje...@splunk.com>
---
 .../main/java/org/apache/pulsar/broker/admin/impl/SinksBase.java   | 7 ++++---
 .../main/java/org/apache/pulsar/broker/admin/impl/SourcesBase.java | 7 ++++---
 2 files changed, 8 insertions(+), 6 deletions(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/SinksBase.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/SinksBase.java
index 416f390..61d3603 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/SinksBase.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/SinksBase.java
@@ -469,8 +469,9 @@ public class SinksBase extends AdminResource implements 
Supplier<WorkerService>
 
     @GET
     @ApiOperation(
-            value = "Fetches a list of supported Pulsar IO sink connectors 
currently running in cluster mode",
-            response = List.class
+            value = "Fetches the list of built-in Pulsar IO sinks",
+            response = ConnectorDefinition.class,
+            responseContainer = "List"
     )
     @ApiResponses(value = {
             @ApiResponse(code = 200, message = "Get builtin sinks 
successfully.")
@@ -489,7 +490,7 @@ public class SinksBase extends AdminResource implements 
Supplier<WorkerService>
 
     @POST
     @ApiOperation(
-            value = "Reload the available built-in connectors, include Source 
and Sink",
+            value = "Reload the built-in connectors, including Sources and 
Sinks",
             response = Void.class
     )
     @ApiResponses(value = {
diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/SourcesBase.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/SourcesBase.java
index d2ddc9e..aba9069 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/SourcesBase.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/SourcesBase.java
@@ -455,8 +455,9 @@ public class SourcesBase extends AdminResource implements 
Supplier<WorkerService
 
     @GET
     @ApiOperation(
-            value = "Fetches a list of supported Pulsar IO source connectors 
currently running in cluster mode",
-            response = List.class
+            value = "Fetches the list of built-in Pulsar IO sources",
+            response = ConnectorDefinition.class,
+            responseContainer = "List"
     )
     @ApiResponses(value = {
             @ApiResponse(code = 403, message = "The requester doesn't have 
admin permissions"),
@@ -479,7 +480,7 @@ public class SourcesBase extends AdminResource implements 
Supplier<WorkerService
 
     @POST
     @ApiOperation(
-            value = "Reload the available built-in connectors, include Source 
and Sink",
+            value = "Reload the built-in connectors, including Sources and 
Sinks",
             response = Void.class
     )
     @ApiResponses(value = {