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 = {