[Bug] The yarn-queue parameter is specified but does not take effect (apache#1330)

* [Bug] The yarn-queue parameter is specified but does not take effect

Author: xujiangfeng001

streamx-console/streamx-console-service/src/main/java/com/streamxhub/streamx/console/core/service/impl/ApplicationServiceImpl.java

@@ -1181,6 +1181,14 @@ public void start(Application appParam, boolean auto) throws Exception {
         }
 
         Map<String, String> dynamicOption = FlinkSubmitter.extractDynamicOptionAsJava(application.getDynamicOptions());
+        //设置yarn.application.queue，如果yarn queue和dynamic option都设置了，那么yarn queue优先级较高
+        if (ExecutionMode.YARN_APPLICATION.equals(application.getExecutionModeEnum())) {
+            if (!application.getHotParamsMap().isEmpty()) {
+                if (application.getHotParamsMap().containsKey(ConfigConst.KEY_YARN_APP_QUEUE())) {
+                    dynamicOption.put(ConfigConst.KEY_YARN_APP_QUEUE(), application.getHotParamsMap().get(ConfigConst.KEY_YARN_APP_QUEUE()).toString());
+                }
+            }
+        }
 
         Map<String, Object> extraParameter = new HashMap<>(0);
         extraParameter.put(ConfigConst.KEY_JOB_ID(), application.getId());