This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a commit to branch dev-2.1.4
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
The following commit(s) were added to refs/heads/dev-2.1.4 by this push:
new b072da386 [Improve] open api config improvement
b072da386 is described below
commit b072da386891b07f93bbec160a89658900ba7e90
Author: benjobs <[email protected]>
AuthorDate: Tue Apr 16 23:22:02 2024 +0800
[Improve] open api config improvement
---
.../console/core/controller/ApplicationBuildPipelineController.java | 3 ---
.../streampark/console/core/controller/ApplicationController.java | 2 --
.../streampark/console/core/controller/SavePointController.java | 2 --
.../streampark/console/core/controller/YarnQueueController.java | 6 ------
4 files changed, 13 deletions(-)
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/ApplicationBuildPipelineController.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/ApplicationBuildPipelineController.java
index c7268fa37..b86a63cfb 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/ApplicationBuildPipelineController.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/ApplicationBuildPipelineController.java
@@ -19,7 +19,6 @@ package org.apache.streampark.console.core.controller;
import org.apache.streampark.console.base.domain.RestResponse;
import org.apache.streampark.console.base.exception.ApiAlertException;
-import org.apache.streampark.console.core.annotation.ApiAccess;
import org.apache.streampark.console.core.annotation.PermissionScope;
import org.apache.streampark.console.core.bean.AppBuildDockerResolvedDetail;
import org.apache.streampark.console.core.entity.AppBuildPipeline;
@@ -71,7 +70,6 @@ public class ApplicationBuildPipelineController {
* @param forceBuild forced start pipeline or not
* @return Whether the pipeline was successfully started
*/
- @ApiAccess
@PermissionScope(app = "#appId")
@PostMapping(value = "build")
@RequiresPermissions("app:create")
@@ -130,7 +128,6 @@ public class ApplicationBuildPipelineController {
* @param appId application id
* @return "pipeline" -> pipeline details, "docker" -> docker resolved
snapshot
*/
- @ApiAccess
@PostMapping("/detail")
@PermissionScope(app = "#appId")
@RequiresPermissions("app:view")
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 2f3ac0cad..97e507492 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
@@ -69,7 +69,6 @@ public class ApplicationController {
@Autowired private ApplicationLogService applicationLogService;
- @ApiAccess
@PostMapping("get")
@PermissionScope(app = "#app.id")
@RequiresPermissions("app:detail")
@@ -115,7 +114,6 @@ public class ApplicationController {
return RestResponse.success(map);
}
- @ApiAccess
@PostMapping("list")
@PermissionScope(team = "#app.teamId")
@RequiresPermissions("app:view")
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/SavePointController.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/SavePointController.java
index ffaece95f..dbb8b2357 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/SavePointController.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/SavePointController.java
@@ -20,7 +20,6 @@ package org.apache.streampark.console.core.controller;
import org.apache.streampark.console.base.domain.RestRequest;
import org.apache.streampark.console.base.domain.RestResponse;
import org.apache.streampark.console.base.exception.InternalException;
-import org.apache.streampark.console.core.annotation.ApiAccess;
import org.apache.streampark.console.core.annotation.PermissionScope;
import org.apache.streampark.console.core.entity.Application;
import org.apache.streampark.console.core.entity.SavePoint;
@@ -66,7 +65,6 @@ public class SavePointController {
return RestResponse.success(deleted);
}
- @ApiAccess
@PostMapping("trigger")
@RequiresPermissions("savepoint:trigger")
@PermissionScope(app = "#savePoint.appId", team = "#savePoint.teamId")
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/YarnQueueController.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/YarnQueueController.java
index b6945a09d..811237532 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/YarnQueueController.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/YarnQueueController.java
@@ -19,7 +19,6 @@ package org.apache.streampark.console.core.controller;
import org.apache.streampark.console.base.domain.RestRequest;
import org.apache.streampark.console.base.domain.RestResponse;
-import org.apache.streampark.console.core.annotation.ApiAccess;
import org.apache.streampark.console.core.entity.YarnQueue;
import org.apache.streampark.console.core.service.YarnQueueService;
@@ -48,27 +47,23 @@ public class YarnQueueController {
* @param yarnQueue optional fields used to search.
* @return RestResponse with IPage<{@link YarnQueue}> object.
*/
- @ApiAccess
@PostMapping("list")
public RestResponse list(RestRequest restRequest, YarnQueue yarnQueue) {
IPage<YarnQueue> queuePage = yarnQueueService.page(yarnQueue, restRequest);
return RestResponse.success(queuePage);
}
- @ApiAccess
@PostMapping("check")
public RestResponse check(YarnQueue yarnQueue) {
return RestResponse.success(yarnQueueService.checkYarnQueue(yarnQueue));
}
- @ApiAccess
@PostMapping("create")
@RequiresPermissions("yarnQueue:create")
public RestResponse create(YarnQueue yarnQueue) {
return RestResponse.success(yarnQueueService.createYarnQueue(yarnQueue));
}
- @ApiAccess
@PostMapping("update")
@RequiresPermissions("yarnQueue:update")
public RestResponse update(YarnQueue yarnQueue) {
@@ -76,7 +71,6 @@ public class YarnQueueController {
return RestResponse.success();
}
- @ApiAccess
@PostMapping("delete")
@RequiresPermissions("yarnQueue:delete")
public RestResponse delete(YarnQueue yarnQueue) {
