From dc1fc86a61d124d862fa042bb3bff659907be4fe Mon Sep 17 00:00:00 2001 From: gongzhongqiang Date: Fri, 26 Jul 2024 23:13:37 +0800 Subject: [PATCH] fix e2e --- .../console/core/controller/ApplicationController.java | 4 ++-- .../src/views/setting/yarn-queue/YarnQueueDrawer.vue | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/ApplicationController.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/ApplicationController.java index 9b53f252cc..47b7de45ad 100644 --- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/ApplicationController.java +++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/ApplicationController.java @@ -275,7 +275,7 @@ public RestResponse verifySchema(String path) { error = "Cannot use the root directory for checkpoints."; } if (error != null) { - restResponse = RestResponse.error(ResponseCode.CODE_FAIL,error,false); + restResponse = RestResponse.error(ResponseCode.CODE_FAIL, error, false); } return restResponse; } @@ -287,7 +287,7 @@ public RestResponse checkSavepointPath(Application app) throws Exception { if (error == null) { return RestResponse.success(true); } - return RestResponse.error(ResponseCode.CODE_FAIL,error,false); + return RestResponse.error(ResponseCode.CODE_FAIL, error, false); } @Permission(app = "#id") diff --git a/streampark-console/streampark-console-webapp/src/views/setting/yarn-queue/YarnQueueDrawer.vue b/streampark-console/streampark-console-webapp/src/views/setting/yarn-queue/YarnQueueDrawer.vue index c7417e6bd8..2b919b3738 100644 --- a/streampark-console/streampark-console-webapp/src/views/setting/yarn-queue/YarnQueueDrawer.vue +++ b/streampark-console/streampark-console-webapp/src/views/setting/yarn-queue/YarnQueueDrawer.vue @@ -64,7 +64,7 @@ }; if (unref(isUpdate)) Object.assign(params, { id: model?.id }); const res = await fetchCheckYarnQueue(params); - if (res.code === ResultEnum.SUCCESS) { + if (res) { return Promise.resolve(); } else { return Promise.reject(res.message);