Skip to content

Commit 7799538

Browse files
authored
[Bug] Property or field 'appId' cannot be found on object of type 'org.apache.streampark.console.core.entity.FlinkApplication' (#4281)
1 parent 5701956 commit 7799538

File tree

1 file changed

+4
-4
lines changed
  • streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller

1 file changed

+4
-4
lines changed

streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/OpenAPIController.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -50,14 +50,14 @@ public class OpenAPIController {
5050
@OpenAPI(name = "flinkStart", header = {
5151
@OpenAPI.Param(name = "Authorization", description = "Access authorization token", required = true, type = String.class)
5252
}, param = {
53-
@OpenAPI.Param(name = "id", description = "current flink application id", required = true, type = Long.class, bindFor = "appId"),
53+
@OpenAPI.Param(name = "id", description = "current flink application id", required = true, type = Long.class),
5454
@OpenAPI.Param(name = "teamId", description = "current user teamId", required = true, type = Long.class),
5555
@OpenAPI.Param(name = "argument", description = "flink program run arguments", required = false, type = String.class, bindFor = "args"),
5656
@OpenAPI.Param(name = "restoreFromSavepoint", description = "restored app from the savepoint or checkpoint", required = false, type = Boolean.class, defaultValue = "false", bindFor = "restoreOrTriggerSavepoint"),
5757
@OpenAPI.Param(name = "savepointPath", description = "savepoint or checkpoint path", required = false, type = String.class),
5858
@OpenAPI.Param(name = "allowNonRestored", description = "ignore savepoint if cannot be restored", required = false, type = Boolean.class, defaultValue = "false"),
5959
})
60-
@Permission(app = "#app.appId", team = "#app.teamId")
60+
@Permission(app = "#app.id", team = "#app.teamId")
6161
@PostMapping("app/start")
6262
@RequiresPermissions("app:start")
6363
public RestResponse flinkStart(FlinkApplication app) throws Exception {
@@ -68,13 +68,13 @@ public RestResponse flinkStart(FlinkApplication app) throws Exception {
6868
@OpenAPI(name = "flinkCancel", header = {
6969
@OpenAPI.Param(name = "Authorization", description = "Access authorization token", required = true, type = String.class)
7070
}, param = {
71-
@OpenAPI.Param(name = "id", description = "current flink application id", required = true, type = Long.class, bindFor = "appId"),
71+
@OpenAPI.Param(name = "id", description = "current flink application id", required = true, type = Long.class),
7272
@OpenAPI.Param(name = "teamId", description = "current user teamId", required = true, type = Long.class),
7373
@OpenAPI.Param(name = "triggerSavepoint", description = "trigger savepoint before taking stopping", required = false, type = Boolean.class, defaultValue = "false", bindFor = "restoreOrTriggerSavepoint"),
7474
@OpenAPI.Param(name = "savepointPath", description = "savepoint path", required = false, type = String.class),
7575
@OpenAPI.Param(name = "drain", description = "send max watermark before canceling", required = false, type = Boolean.class, defaultValue = "false"),
7676
})
77-
@Permission(app = "#app.appId", team = "#app.teamId")
77+
@Permission(app = "#app.id", team = "#app.teamId")
7878
@PostMapping("app/cancel")
7979
@RequiresPermissions("app:cancel")
8080
public RestResponse flinkCancel(FlinkApplication app) throws Exception {

0 commit comments

Comments
 (0)