You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampark.apache.org by be...@apache.org on 2024/04/16 12:12:33 UTC
(incubator-streampark) branch dev-2.1.4 updated: [Improve] get token api bug fixed.
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 f87baa03e [Improve] get token api bug fixed.
f87baa03e is described below
commit f87baa03ea230a8a1216ce32226ab2d28ae091e4
Author: benjobs <be...@gmail.com>
AuthorDate: Tue Apr 16 20:12:21 2024 +0800
[Improve] get token api bug fixed.
---
.../streampark/console/system/controller/AccessTokenController.java | 6 ++----
.../apache/streampark/console/system/controller/UserController.java | 2 +-
2 files changed, 3 insertions(+), 5 deletions(-)
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 62434c62b..f6cddef20 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
@@ -171,11 +171,10 @@ public class AccessTokenController {
if ("/flink/app/start".equalsIgnoreCase(path)) {
resultCURL =
curlBuilder
+ .addFormData("id", appId)
+ .addFormData("teamId", teamId)
.addFormData("allowNonRestored", "false")
- .addFormData("savePoint", "")
.addFormData("savePointed", "false")
- .addFormData("teamId", teamId)
- .addFormData("id", appId)
.build();
} else if ("/flink/app/cancel".equalsIgnoreCase(path)) {
resultCURL =
@@ -184,7 +183,6 @@ public class AccessTokenController {
.addFormData("teamId", teamId)
.addFormData("savePointed", "false")
.addFormData("drain", "false")
- .addFormData("savePoint", "")
.build();
}
return RestResponse.success(resultCURL);
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/controller/UserController.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/controller/UserController.java
index f51c2e4a3..80e41306f 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/controller/UserController.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/controller/UserController.java
@@ -98,8 +98,8 @@ public class UserController {
}
@Operation(summary = "List without token users")
- @PermissionScope(user = "#userId")
@RequiresPermissions("token:add")
+ @PostMapping("getNoTokenUser")
public RestResponse getNoTokenUser() {
List<User> userList = this.userService.getNoTokenUser();
return RestResponse.success(userList);