[incubator-streampark] branch dev updated: [Bug] task modification of yarn application cluster failed (#1920)

[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 1d9d02092  [Bug] task modification of yarn application cluster failed 
(#1920)
1d9d02092 is described below

commit 1d9d020924ef43b1514df2d0f05d18c4d03ac4aa
Author: xujiangfeng001 <104614523+xujiangfeng...@users.noreply.github.com>
AuthorDate: Mon Oct 31 10:24:19 2022 +0800

     [Bug] task modification of yarn application cluster failed (#1920)
    
    * [Bug] StreamPark cannot search for failed status tasks
    
    * [Bug] task modification of yarn application cluster failed
---
 .../src/views/flink/app/EditStreamPark.vue                  | 13 +++++++++++++
 1 file changed, 13 insertions(+)

diff --git 
a/streampark-console/streampark-console-webapp/src/views/flink/app/EditStreamPark.vue
 
b/streampark-console/streampark-console-webapp/src/views/flink/app/EditStreamPark.vue
index a3527dc55..252ce90b0 100644
--- 
a/streampark-console/streampark-console-webapp/src/views/flink/app/EditStreamPark.vue
+++ 
b/streampark-console/streampark-console-webapp/src/views/flink/app/EditStreamPark.vue
@@ -2417,6 +2417,12 @@ export default {
       } else {
         config = null
       }
+      if (values.yarnSessionClusterId) {
+        const cluster = this.flinkClusters.filter(c => c.clusterId === 
values.yarnSessionClusterId && c.clusterState === 1)[0] || null
+        values.clusterId = cluster.id
+        values.flinkClusterId = cluster.id
+        values.yarnSessionClusterId = cluster.clusterId
+      }
       const configId = this.strategy === 1 ? this.configId : null
       const params = {
         id: this.app.id,
@@ -2475,6 +2481,13 @@ export default {
         config = null
       }
 
+      if (values.yarnSessionClusterId) {
+        const cluster = this.flinkClusters.filter(c => c.clusterId === 
values.yarnSessionClusterId && c.clusterState === 1)[0] || null
+        values.clusterId = cluster.id
+        values.flinkClusterId = cluster.id
+        values.yarnSessionClusterId = cluster.clusterId
+      }
+
       const params = {
         id: this.app.id,
         sqlId: this.defaultFlinkSqlId || null,