[incubator-streampark] branch dev updated: [Bug] The queue parameters were not passed to the backend service in Yarn per job mode #2669 (#2670)

[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 11ad9b0ad [Bug] The queue parameters were not passed to the backend 
service in Yarn per job mode #2669 (#2670)
11ad9b0ad is described below

commit 11ad9b0ad8753aca7f10670eee242be2fe1e5cef
Author: macksonmu <mackson...@gmail.com>
AuthorDate: Fri Apr 21 10:53:37 2023 +0800

    [Bug] The queue parameters were not passed to the backend service in Yarn 
per job mode #2669 (#2670)
---
 .../streampark-console-webapp/src/views/flink/app/utils/index.ts        | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/streampark-console/streampark-console-webapp/src/views/flink/app/utils/index.ts
 
b/streampark-console/streampark-console-webapp/src/views/flink/app/utils/index.ts
index 046b6a35f..98857e361 100644
--- 
a/streampark-console/streampark-console-webapp/src/views/flink/app/utils/index.ts
+++ 
b/streampark-console/streampark-console-webapp/src/views/flink/app/utils/index.ts
@@ -161,7 +161,7 @@ export function handleIsStart(app: Recordable, optionApps: 
Recordable) {
 }
 
 export function handleYarnQueue(values: Recordable) {
-  if (values.executionMode == ExecModeEnum.YARN_APPLICATION) {
+  if (values.executionMode == ExecModeEnum.YARN_APPLICATION || 
values.executionMode == ExecModeEnum.YARN_PER_JOB) {
     const queue = values['yarnQueue'];
     if (queue != null && queue !== '' && queue !== undefined) {
       return queue;