You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampark.apache.org by be...@apache.org on 2022/10/31 02:24:25 UTC
[incubator-streampark] branch dev updated: [Bug] task modification of yarn application cluster failed (#1920)
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 <10...@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,