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

nicholasjiang pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/paimon-webui.git


The following commit(s) were added to refs/heads/main by this push:
     new 2474879a [Improvement] Remove permission control annotations (#327)
2474879a is described below

commit 2474879adce2c107d2d532aa4172cb26a09a093a
Author: s7monk <[email protected]>
AuthorDate: Tue Jun 11 12:35:50 2024 +0800

    [Improvement] Remove permission control annotations (#327)
---
 .../paimon/web/server/controller/CdcJobDefinitionController.java   | 1 +
 .../org/apache/paimon/web/server/controller/JobController.java     | 7 ++++---
 2 files changed, 5 insertions(+), 3 deletions(-)

diff --git 
a/paimon-web-server/src/main/java/org/apache/paimon/web/server/controller/CdcJobDefinitionController.java
 
b/paimon-web-server/src/main/java/org/apache/paimon/web/server/controller/CdcJobDefinitionController.java
index 34194863..60079f09 100644
--- 
a/paimon-web-server/src/main/java/org/apache/paimon/web/server/controller/CdcJobDefinitionController.java
+++ 
b/paimon-web-server/src/main/java/org/apache/paimon/web/server/controller/CdcJobDefinitionController.java
@@ -88,6 +88,7 @@ public class CdcJobDefinitionController {
         return R.succeed();
     }
 
+    @SaCheckPermission("cdc:job:submit")
     @PostMapping("{id}/submit")
     public R<Void> submit(@PathVariable Integer id, @RequestBody 
CdcJobSubmitDTO cdcJobSubmitDTO) {
         return cdcJobDefinitionService.submit(id, cdcJobSubmitDTO);
diff --git 
a/paimon-web-server/src/main/java/org/apache/paimon/web/server/controller/JobController.java
 
b/paimon-web-server/src/main/java/org/apache/paimon/web/server/controller/JobController.java
index a7be95d1..d07a467d 100644
--- 
a/paimon-web-server/src/main/java/org/apache/paimon/web/server/controller/JobController.java
+++ 
b/paimon-web-server/src/main/java/org/apache/paimon/web/server/controller/JobController.java
@@ -31,6 +31,7 @@ import org.apache.paimon.web.server.data.vo.ResultDataVO;
 import org.apache.paimon.web.server.service.JobService;
 
 import cn.dev33.satoken.annotation.SaCheckPermission;
+import cn.dev33.satoken.annotation.SaIgnore;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.GetMapping;
@@ -61,7 +62,7 @@ public class JobController {
         }
     }
 
-    @SaCheckPermission("playground:job:fetch")
+    @SaIgnore
     @PostMapping("/fetch")
     public R<ResultDataVO> fetchResult(@RequestBody ResultFetchDTO 
resultFetchDTO) {
         try {
@@ -84,7 +85,7 @@ public class JobController {
         return R.succeed(jobService.listJobsByPage(current, size));
     }
 
-    @SaCheckPermission("playground:job:query")
+    @SaIgnore
     @GetMapping("/status/get/{jobId}")
     public R<JobStatusVO> getJobStatus(@PathVariable("jobId") String jobId) {
         JobInfo job = jobService.getJobById(jobId);
@@ -111,7 +112,7 @@ public class JobController {
         }
     }
 
-    @SaCheckPermission("playground:job:refresh")
+    @SaIgnore
     @PostMapping("/refresh")
     public R<Void> refresh() {
         jobService.refreshJobStatus("Flink");

Reply via email to