[incubator-streampark] branch dev updated: [Bug] create queue error #2659 (#2663)

[benjobs]

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

benjobs pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git


The following commit(s) were added to refs/heads/dev by this push:
     new cabf2f582 [Bug] create queue error #2659 (#2663)
cabf2f582 is described below

commit cabf2f582718422efd790d72fc34d6f8120ac711
Author: macksonmu <mackson...@gmail.com>
AuthorDate: Wed Apr 19 19:25:39 2023 +0800

    [Bug] create queue error #2659 (#2663)
---
 .../streampark/console/core/controller/YarnQueueController.java  | 9 ++++-----
 1 file changed, 4 insertions(+), 5 deletions(-)

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 4f05dd404..85436e2d5 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
@@ -32,7 +32,6 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
@@ -63,7 +62,7 @@ public class YarnQueueController {
   @Operation(summary = "Check yarn queue valid")
   @ApiAccess
   @PostMapping("check")
-  public RestResponse check(@RequestBody YarnQueue yarnQueue) {
+  public RestResponse check(YarnQueue yarnQueue) {
     return RestResponse.success(yarnQueueService.checkYarnQueue(yarnQueue));
   }
 
@@ -71,7 +70,7 @@ public class YarnQueueController {
   @ApiAccess
   @PostMapping("create")
   @RequiresPermissions("yarnQueue:create")
-  public RestResponse create(@RequestBody YarnQueue yarnQueue) {
+  public RestResponse create(YarnQueue yarnQueue) {
     return RestResponse.success(yarnQueueService.createYarnQueue(yarnQueue));
   }
 
@@ -79,7 +78,7 @@ public class YarnQueueController {
   @ApiAccess
   @PostMapping("update")
   @RequiresPermissions("yarnQueue:update")
-  public RestResponse update(@RequestBody YarnQueue yarnQueue) {
+  public RestResponse update(YarnQueue yarnQueue) {
     yarnQueueService.updateYarnQueue(yarnQueue);
     return RestResponse.success();
   }
@@ -90,7 +89,7 @@ public class YarnQueueController {
   @ApiAccess
   @PostMapping("delete")
   @RequiresPermissions("yarnQueue:delete")
-  public RestResponse delete(@RequestBody YarnQueue yarnQueue) {
+  public RestResponse delete(YarnQueue yarnQueue) {
     yarnQueueService.deleteYarnQueue(yarnQueue);
     return RestResponse.success();
   }