This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a commit to branch dev-2.1.5
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
The following commit(s) were added to refs/heads/dev-2.1.5 by this push:
new 764e2b565 [Improve] Remove swagger dependencies. (#3893)
764e2b565 is described below
commit 764e2b56582919ba1be56473d51f0fc28225dfe6
Author: lvshaokang <[email protected]>
AuthorDate: Fri Jul 19 21:43:10 2024 +0800
[Improve] Remove swagger dependencies. (#3893)
* [Improve] Remove swagger dependencies.
* remove
---
.../streampark-console-service/pom.xml | 21 -----
.../console/base/config/OpenapiConfig.java | 76 -----------------
.../console/base/domain/ApiDocConstant.java | 23 -----
.../console/base/domain/RestRequest.java | 9 --
.../console/core/bean/AlertConfigWithParams.java | 14 ----
.../console/core/bean/AlertDingTalkParams.java | 11 ---
.../console/core/bean/AlertEmailParams.java | 3 -
.../console/core/bean/AlertHttpCallbackParams.java | 10 ---
.../console/core/bean/AlertLarkParams.java | 10 ---
.../console/core/bean/AlertWeComParams.java | 3 -
.../core/controller/ApplicationController.java | 98 +---------------------
.../console/core/controller/IndexController.java | 2 -
.../system/controller/AccessTokenController.java | 4 +-
.../system/controller/PassportController.java | 2 -
14 files changed, 4 insertions(+), 282 deletions(-)
diff --git a/streampark-console/streampark-console-service/pom.xml
b/streampark-console/streampark-console-service/pom.xml
index 600148ad3..f906b4500 100644
--- a/streampark-console/streampark-console-service/pom.xml
+++ b/streampark-console/streampark-console-service/pom.xml
@@ -43,8 +43,6 @@
<docker.client.version>3.2.13</docker.client.version>
- <knife4j-openapi3.version>4.0.0</knife4j-openapi3.version>
- <springdoc-openapi-ui.version>1.6.9</springdoc-openapi-ui.version>
<commons-compress.version>1.21</commons-compress.version>
<javax-mail.version>1.4.7</javax-mail.version>
<jsch.version>0.2.11</jsch.version>
@@ -378,25 +376,6 @@
<artifactId>jackson-module-scala_${scala.binary.version}</artifactId>
</dependency>
- <!-- openapi -->
- <dependency>
- <groupId>org.springdoc</groupId>
- <artifactId>springdoc-openapi-ui</artifactId>
- <version>${springdoc-openapi-ui.version}</version>
- </dependency>
-
- <dependency>
- <groupId>com.github.xiaoymin</groupId>
- <artifactId>knife4j-openapi3-spring-boot-starter</artifactId>
- <version>${knife4j-openapi3.version}</version>
- <exclusions>
- <exclusion>
- <artifactId>springdoc-openapi-webflux-core</artifactId>
- <groupId>org.springdoc</groupId>
- </exclusion>
- </exclusions>
- </dependency>
-
<!--Test dependencies start.-->
<dependency>
<groupId>org.springframework.boot</groupId>
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/config/OpenapiConfig.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/config/OpenapiConfig.java
deleted file mode 100644
index 602a79c71..000000000
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/config/OpenapiConfig.java
+++ /dev/null
@@ -1,76 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.streampark.console.base.config;
-
-import org.apache.http.HttpHeaders;
-
-import com.github.xiaoymin.knife4j.spring.annotations.EnableKnife4j;
-import io.swagger.v3.oas.models.Components;
-import io.swagger.v3.oas.models.OpenAPI;
-import io.swagger.v3.oas.models.info.Contact;
-import io.swagger.v3.oas.models.info.Info;
-import io.swagger.v3.oas.models.info.License;
-import io.swagger.v3.oas.models.security.SecurityRequirement;
-import io.swagger.v3.oas.models.security.SecurityScheme;
-import org.springdoc.core.GroupedOpenApi;
-import
org.springframework.boot.autoconfigure.condition.ConditionalOnWebApplication;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
-
-import java.util.Collections;
-
-@EnableKnife4j
-@Configuration
-@ConditionalOnWebApplication
-public class OpenapiConfig implements WebMvcConfigurer {
-
- private final String[] paths = new String[] {"/flink/app/start",
"/flink/app/cancel"};
-
- @Bean
- public OpenAPI apiV1Info() {
- return new OpenAPI()
- .info(
- new Info()
- .title("Apache StreamPark Open API")
- .description("Apache StreamPark Open API for third-party
system integration")
- .contact(
- new Contact()
- .name("Apache StreamPark")
- .url("https://streampark.apache.org/";)
- .email("[email protected]"))
- .version("2.1.5")
- .license(new License().name("Apache-2.0 license")))
- .components(
- new Components()
- .addSecuritySchemes(
- HttpHeaders.AUTHORIZATION,
- new SecurityScheme()
- .type(SecurityScheme.Type.APIKEY)
- .name(HttpHeaders.AUTHORIZATION)
- .in(SecurityScheme.In.HEADER)))
- .security(
- Collections.singletonList(
- new SecurityRequirement().addList(HttpHeaders.AUTHORIZATION)));
- }
-
- @Bean
- public GroupedOpenApi publicApiV1() {
- return GroupedOpenApi.builder().group("Open
API").pathsToMatch(paths).build();
- }
-}
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/ApiDocConstant.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/ApiDocConstant.java
deleted file mode 100644
index 0a43d05aa..000000000
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/ApiDocConstant.java
+++ /dev/null
@@ -1,23 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.streampark.console.base.domain;
-
-public class ApiDocConstant {
-
- public static final String OPENAPI_TAG = "OpenAPI";
-}
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/RestRequest.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/RestRequest.java
index b51cb35ff..8ffda5927 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/RestRequest.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/RestRequest.java
@@ -17,31 +17,22 @@
package org.apache.streampark.console.base.domain;
-import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Getter;
import lombok.Setter;
-import org.springdoc.api.annotations.ParameterObject;
import java.io.Serializable;
-@ParameterObject
@Getter
@Setter
public class RestRequest implements Serializable {
private static final long serialVersionUID = 1L;
- @Schema(example = "10", required = true)
private int pageSize = 10;
- @Schema(example = "1", required = true)
private int pageNum = 1;
- @Schema(example = "", description = "e.g. create_time")
private String sortField = Constant.DEFAULT_SORT_FIELD;
- @Schema(
- example = "",
- allowableValues = {"asc", "desc"})
private String sortOrder = Constant.ORDER_DESC;
}
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertConfigWithParams.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertConfigWithParams.java
index 93e676bc9..6aa8b86ea 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertConfigWithParams.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertConfigWithParams.java
@@ -23,7 +23,6 @@ import org.apache.streampark.console.core.entity.AlertConfig;
import org.apache.commons.lang3.StringUtils;
import com.fasterxml.jackson.core.JsonProcessingException;
-import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Getter;
import lombok.Setter;
import lombok.extern.slf4j.Slf4j;
@@ -31,40 +30,27 @@ import org.springframework.beans.BeanUtils;
import java.io.Serializable;
-@Schema(name = "AlertConfig")
@Getter
@Setter
@Slf4j
public class AlertConfigWithParams implements Serializable {
- @Schema(example = "1")
private Long id;
- @Schema(example = "100000")
private Long userId;
- @Schema(example = "test-alert")
private String alertName;
- @Schema(
- example = "1",
- description =
- "base type, email 1, dink-talk 2, we-com 4, http callback 8, lark
16, also choose a combination, e.g. 3 means email + dink-talk")
private Integer alertType;
- @Schema(description = "email alert parameters")
private AlertEmailParams emailParams;
- @Schema(description = "ding-talk alert parameters")
private AlertDingTalkParams dingTalkParams;
- @Schema(description = "we-com alert parameters")
private AlertWeComParams weComParams;
- @Schema(description = "http callback alert parameters")
private AlertHttpCallbackParams httpCallbackParams;
- @Schema(description = "lark alert parameters")
private AlertLarkParams larkParams;
public static AlertConfigWithParams of(AlertConfig config) {
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertDingTalkParams.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertDingTalkParams.java
index cb70b031c..ec8a81b88 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertDingTalkParams.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertDingTalkParams.java
@@ -18,7 +18,6 @@
package org.apache.streampark.console.core.bean;
import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
-import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Getter;
import lombok.Setter;
@@ -26,31 +25,21 @@ import javax.validation.constraints.NotBlank;
import java.io.Serializable;
-@Schema(name = "AlertDingTalk")
@Getter
@Setter
@JsonIgnoreProperties(ignoreUnknown = true)
public class AlertDingTalkParams implements Serializable {
- @Schema(description = "dink-talk token")
@NotBlank(message = "The access token of DingTalk must be not empty")
private String token;
- @Schema(description = "phone numbers, use ',' to split multiple phone
numbers")
private String contacts;
- @Schema(description = "ding-talk url")
private String alertDingURL;
- @Schema(description = "is @all", example = "false", defaultValue = "false")
private Boolean isAtAll = false;
- @Schema(
- description = "is ding-talk robot secret enabled",
- example = "false",
- defaultValue = "false")
private Boolean secretEnable = false;
- @Schema(description = "ding-talk robot webhook secret token")
private String secretToken;
}
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertEmailParams.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertEmailParams.java
index c83d05e66..32946d095 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertEmailParams.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertEmailParams.java
@@ -18,7 +18,6 @@
package org.apache.streampark.console.core.bean;
import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
-import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Getter;
import lombok.Setter;
@@ -26,13 +25,11 @@ import javax.validation.constraints.NotBlank;
import java.io.Serializable;
-@Schema(name = "AlertEmail")
@Getter
@Setter
@JsonIgnoreProperties(ignoreUnknown = true)
public class AlertEmailParams implements Serializable {
- @Schema(example = "[email protected]", description = "email address")
@NotBlank(message = "The address of email must be not empty")
private String contacts;
}
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertHttpCallbackParams.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertHttpCallbackParams.java
index b94cbf0aa..1af3f5be5 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertHttpCallbackParams.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertHttpCallbackParams.java
@@ -18,7 +18,6 @@
package org.apache.streampark.console.core.bean;
import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
-import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Getter;
import lombok.Setter;
@@ -26,26 +25,17 @@ import javax.validation.constraints.NotBlank;
import java.io.Serializable;
-@Schema(name = "AlertHttpCallback")
@Getter
@Setter
@JsonIgnoreProperties(ignoreUnknown = true)
public class AlertHttpCallbackParams implements Serializable {
- @Schema(description = "http callback url")
@NotBlank(message = "The url of callback must be not empty")
private String url;
- @Schema(
- description = "http method",
- defaultValue = "POST",
- example = "POST",
- allowableValues = {"POST", "GET"})
private String method = "POST";
- @Schema(description = "content type header", example = "application/json")
private String contentType;
- @Schema(description = "use freemarker template replace the parameters")
private String requestTemplate;
}
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertLarkParams.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertLarkParams.java
index e6f4fc64f..74f42c4a4 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertLarkParams.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertLarkParams.java
@@ -18,7 +18,6 @@
package org.apache.streampark.console.core.bean;
import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
-import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Getter;
import lombok.Setter;
@@ -26,26 +25,17 @@ import javax.validation.constraints.NotBlank;
import java.io.Serializable;
-@Schema(name = "AlertLark")
@Getter
@Setter
@JsonIgnoreProperties(ignoreUnknown = true)
public class AlertLarkParams implements Serializable {
- @Schema(description = "lark access token")
@NotBlank(message = "The access token of Lark must be not empty")
private String token;
- @Schema(description = "is @all", example = "false", implementation =
boolean.class)
private Boolean isAtAll = false;
- @Schema(
- description = "is lark robot secret enabled",
- example = "false",
- defaultValue = "false",
- implementation = boolean.class)
private Boolean secretEnable = false;
- @Schema(description = "lark robot webhook secret token")
private String secretToken;
}
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertWeComParams.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertWeComParams.java
index de8dced07..ad588a5a1 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertWeComParams.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertWeComParams.java
@@ -18,7 +18,6 @@
package org.apache.streampark.console.core.bean;
import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
-import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Getter;
import lombok.Setter;
@@ -26,13 +25,11 @@ import javax.validation.constraints.NotBlank;
import java.io.Serializable;
-@Schema(name = "AlertWeCom")
@Getter
@Setter
@JsonIgnoreProperties(ignoreUnknown = true)
public class AlertWeComParams implements Serializable {
- @Schema(name = "token", description = "we-com token")
@NotBlank(message = "The access token of WeCom must be not empty")
private String token;
}
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/ApplicationController.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/ApplicationController.java
index 60beea7ac..b2e6ace9e 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/ApplicationController.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/ApplicationController.java
@@ -19,7 +19,6 @@ package org.apache.streampark.console.core.controller;
import org.apache.streampark.common.util.Utils;
import org.apache.streampark.common.util.YarnUtils;
-import org.apache.streampark.console.base.domain.ApiDocConstant;
import org.apache.streampark.console.base.domain.RestRequest;
import org.apache.streampark.console.base.domain.RestResponse;
import org.apache.streampark.console.base.exception.InternalException;
@@ -37,11 +36,6 @@ import
org.apache.streampark.console.core.service.ApplicationService;
import org.apache.shiro.authz.annotation.RequiresPermissions;
import com.baomidou.mybatisplus.core.metadata.IPage;
-import io.swagger.v3.oas.annotations.Operation;
-import io.swagger.v3.oas.annotations.Parameter;
-import io.swagger.v3.oas.annotations.Parameters;
-import io.swagger.v3.oas.annotations.enums.ParameterIn;
-import io.swagger.v3.oas.annotations.media.Schema;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.validation.annotation.Validated;
@@ -88,7 +82,7 @@ public class ApplicationController {
@PermissionScope(app = "#app.id", team = "#app.teamId")
@PostMapping(value = "copy")
@RequiresPermissions("app:copy")
- public RestResponse copy(@Parameter(hidden = true) Application app) throws
IOException {
+ public RestResponse copy(Application app) throws IOException {
Long id = applicationService.copy(app);
Map<String, String> data = new HashMap<>();
data.put("id", Long.toString(id));
@@ -97,7 +91,6 @@ public class ApplicationController {
: RestResponse.success(true).data(data);
}
- @Operation(summary = "Update application")
@AppUpdated
@PermissionScope(app = "#app.id")
@PostMapping("update")
@@ -148,53 +141,11 @@ public class ApplicationController {
return RestResponse.success(stateEnum.get());
}
- @Operation(
- summary = "Start application",
- tags = {ApiDocConstant.OPENAPI_TAG})
- @Parameters({
- @Parameter(
- name = "Authorization",
- description = "Access authorization token",
- in = ParameterIn.HEADER,
- required = true,
- schema = @Schema(implementation = String.class)),
- @Parameter(
- name = "id",
- description = "start app id",
- in = ParameterIn.QUERY,
- required = true,
- example = "100000",
- schema = @Schema(implementation = Long.class)),
- @Parameter(
- name = "teamId",
- description = "current user teamId",
- in = ParameterIn.QUERY,
- required = true,
- example = "100000",
- schema = @Schema(implementation = Long.class)),
- @Parameter(
- name = "savePointed",
- description = "restored app from the savepoint or latest checkpoint",
- in = ParameterIn.QUERY,
- example = "false",
- schema = @Schema(implementation = boolean.class, defaultValue =
"false")),
- @Parameter(
- name = "savePoint",
- description = "savepoint or checkpoint path",
- in = ParameterIn.QUERY,
- required = false,
- schema = @Schema(implementation = String.class)),
- @Parameter(
- name = "allowNonRestored",
- description = "ignore savepoint if cannot be restored",
- in = ParameterIn.QUERY,
- schema = @Schema(implementation = boolean.class, defaultValue =
"false"))
- })
@ApiAccess
@PermissionScope(app = "#app.id", team = "#app.teamId")
@PostMapping(value = "start")
@RequiresPermissions("app:start")
- public RestResponse start(@Parameter(hidden = true) Application app) {
+ public RestResponse start(Application app) {
try {
applicationService.checkEnv(app);
applicationService.start(app, false);
@@ -204,53 +155,10 @@ public class ApplicationController {
}
}
- @Operation(
- summary = "Cancel application",
- tags = {ApiDocConstant.OPENAPI_TAG})
- @ApiAccess
- @Parameters({
- @Parameter(
- name = "Authorization",
- description = "Access authorization token",
- in = ParameterIn.HEADER,
- required = true,
- schema = @Schema(implementation = String.class)),
- @Parameter(
- name = "id",
- description = "cancel app id",
- in = ParameterIn.QUERY,
- required = true,
- example = "100000",
- schema = @Schema(implementation = Long.class)),
- @Parameter(
- name = "teamId",
- description = "current user teamId",
- in = ParameterIn.QUERY,
- required = true,
- example = "100000",
- schema = @Schema(implementation = Long.class)),
- @Parameter(
- name = "savePointed",
- description = "trigger savepoint before taking stopping",
- in = ParameterIn.QUERY,
- schema = @Schema(implementation = boolean.class, defaultValue =
"false")),
- @Parameter(
- name = "savePoint",
- description = "savepoint path",
- in = ParameterIn.QUERY,
- example = "hdfs:///savepoint/100000",
- schema = @Schema(implementation = String.class)),
- @Parameter(
- name = "drain",
- description = "send max watermark before canceling",
- in = ParameterIn.QUERY,
- example = "false",
- schema = @Schema(implementation = boolean.class, defaultValue =
"false"))
- })
@PermissionScope(app = "#app.id", team = "#app.teamId")
@PostMapping(value = "cancel")
@RequiresPermissions("app:cancel")
- public RestResponse cancel(@Parameter(hidden = true) Application app) throws
Exception {
+ public RestResponse cancel(Application app) throws Exception {
applicationService.cancel(app);
return RestResponse.success();
}
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/IndexController.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/IndexController.java
index ca3ddf6d1..950a4d130 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/IndexController.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/IndexController.java
@@ -17,7 +17,6 @@
package org.apache.streampark.console.core.controller;
-import io.swagger.v3.oas.annotations.Hidden;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
@@ -27,7 +26,6 @@ import org.springframework.web.servlet.ModelAndView;
@Controller
public class IndexController {
- @Hidden
@GetMapping("/")
public ModelAndView index() {
return new ModelAndView("/index.html");
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/controller/AccessTokenController.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/controller/AccessTokenController.java
index 1eb982107..07830c502 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/controller/AccessTokenController.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/controller/AccessTokenController.java
@@ -30,7 +30,6 @@ import
org.apache.streampark.console.system.service.AccessTokenService;
import org.apache.shiro.authz.annotation.RequiresPermissions;
import com.baomidou.mybatisplus.core.metadata.IPage;
-import io.swagger.v3.oas.annotations.Parameter;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.DeleteMapping;
import org.springframework.web.bind.annotation.PostMapping;
@@ -81,8 +80,7 @@ public class AccessTokenController {
/** query token list */
@PostMapping(value = "list")
@RequiresPermissions("token:view")
- public RestResponse tokensList(
- RestRequest restRequest, @Parameter(hidden = true) AccessToken
accessToken) {
+ public RestResponse tokensList(RestRequest restRequest, AccessToken
accessToken) {
IPage<AccessToken> accessTokens = accessTokenService.page(accessToken,
restRequest);
return RestResponse.success(accessTokens);
}
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/controller/PassportController.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/controller/PassportController.java
index 5736a7cdd..c6c9a7ba4 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/controller/PassportController.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/controller/PassportController.java
@@ -32,7 +32,6 @@ import org.apache.commons.lang3.RandomStringUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.shiro.SecurityUtils;
-import io.swagger.v3.oas.annotations.Operation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.PostMapping;
@@ -107,7 +106,6 @@ public class PassportController {
return new RestResponse().data(userInfo);
}
- @Operation(summary = "Signout")
@PostMapping("signout")
public RestResponse signout() {
SecurityUtils.getSubject().logout();
