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/streampark.git
The following commit(s) were added to refs/heads/dev by this push:
new 77995387d [Bug] Property or field 'appId' cannot be found on object of
type 'org.apache.streampark.console.core.entity.FlinkApplication' (#4281)
77995387d is described below
commit 77995387dfaab2073cf54174607c05bee9088abc
Author: CuteShaos <57027034+cutesh...@users.noreply.github.com>
AuthorDate: Sun Aug 31 22:59:10 2025 +0800
[Bug] Property or field 'appId' cannot be found on object of type
'org.apache.streampark.console.core.entity.FlinkApplication' (#4281)
---
.../streampark/console/core/controller/OpenAPIController.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/OpenAPIController.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/OpenAPIController.java
index 3c85c0842..ede5b4673 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/OpenAPIController.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/OpenAPIController.java
@@ -50,14 +50,14 @@ public class OpenAPIController {
@OpenAPI(name = "flinkStart", header = {
@OpenAPI.Param(name = "Authorization", description = "Access
authorization token", required = true, type = String.class)
}, param = {
- @OpenAPI.Param(name = "id", description = "current flink
application id", required = true, type = Long.class, bindFor = "appId"),
+ @OpenAPI.Param(name = "id", description = "current flink
application id", required = true, type = Long.class),
@OpenAPI.Param(name = "teamId", description = "current user
teamId", required = true, type = Long.class),
@OpenAPI.Param(name = "argument", description = "flink program run
arguments", required = false, type = String.class, bindFor = "args"),
@OpenAPI.Param(name = "restoreFromSavepoint", description =
"restored app from the savepoint or checkpoint", required = false, type =
Boolean.class, defaultValue = "false", bindFor = "restoreOrTriggerSavepoint"),
@OpenAPI.Param(name = "savepointPath", description = "savepoint or
checkpoint path", required = false, type = String.class),
@OpenAPI.Param(name = "allowNonRestored", description = "ignore
savepoint if cannot be restored", required = false, type = Boolean.class,
defaultValue = "false"),
})
- @Permission(app = "#app.appId", team = "#app.teamId")
+ @Permission(app = "#app.id", team = "#app.teamId")
@PostMapping("app/start")
@RequiresPermissions("app:start")
public RestResponse flinkStart(FlinkApplication app) throws Exception {
@@ -68,13 +68,13 @@ public class OpenAPIController {
@OpenAPI(name = "flinkCancel", header = {
@OpenAPI.Param(name = "Authorization", description = "Access
authorization token", required = true, type = String.class)
}, param = {
- @OpenAPI.Param(name = "id", description = "current flink
application id", required = true, type = Long.class, bindFor = "appId"),
+ @OpenAPI.Param(name = "id", description = "current flink
application id", required = true, type = Long.class),
@OpenAPI.Param(name = "teamId", description = "current user
teamId", required = true, type = Long.class),
@OpenAPI.Param(name = "triggerSavepoint", description = "trigger
savepoint before taking stopping", required = false, type = Boolean.class,
defaultValue = "false", bindFor = "restoreOrTriggerSavepoint"),
@OpenAPI.Param(name = "savepointPath", description = "savepoint
path", required = false, type = String.class),
@OpenAPI.Param(name = "drain", description = "send max watermark
before canceling", required = false, type = Boolean.class, defaultValue =
"false"),
})
- @Permission(app = "#app.appId", team = "#app.teamId")
+ @Permission(app = "#app.id", team = "#app.teamId")
@PostMapping("app/cancel")
@RequiresPermissions("app:cancel")
public RestResponse flinkCancel(FlinkApplication app) throws Exception {
