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");