You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampark.apache.org by kr...@apache.org on 2023/10/08 11:01:28 UTC
[incubator-streampark] branch dev updated: [Improve] Flink cluster executionMode improvement (#3223)
This is an automated email from the ASF dual-hosted git repository.
kriszu 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 2c4888015 [Improve] Flink cluster executionMode improvement (#3223)
2c4888015 is described below
commit 2c488801586e65f85eee97d3d393e49aeb17945c
Author: benjobs <be...@apache.org>
AuthorDate: Sun Oct 8 06:01:19 2023 -0500
[Improve] Flink cluster executionMode improvement (#3223)
---
.../src/api/flink/setting/types/flinkCluster.type.ts | 2 --
.../src/views/setting/FlinkCluster/index.vue | 10 ++++++++--
2 files changed, 8 insertions(+), 4 deletions(-)
diff --git a/streampark-console/streampark-console-webapp/src/api/flink/setting/types/flinkCluster.type.ts b/streampark-console/streampark-console-webapp/src/api/flink/setting/types/flinkCluster.type.ts
index 5d9412f24..43876f0be 100644
--- a/streampark-console/streampark-console-webapp/src/api/flink/setting/types/flinkCluster.type.ts
+++ b/streampark-console/streampark-console-webapp/src/api/flink/setting/types/flinkCluster.type.ts
@@ -36,6 +36,4 @@ export interface FlinkCluster {
exception?: any;
clusterState: number;
createTime: string;
- executionModeEnum: string;
- clusterStateEnum: string;
}
diff --git a/streampark-console/streampark-console-webapp/src/views/setting/FlinkCluster/index.vue b/streampark-console/streampark-console-webapp/src/views/setting/FlinkCluster/index.vue
index 4b330ca73..ed3b88d76 100644
--- a/streampark-console/streampark-console-webapp/src/views/setting/FlinkCluster/index.vue
+++ b/streampark-console/streampark-console-webapp/src/views/setting/FlinkCluster/index.vue
@@ -26,7 +26,7 @@
<script lang="ts" setup name="FlinkClusterSetting">
import { onMounted, ref } from 'vue';
import { SvgIcon } from '/@/components/Icon';
- import { List, Popconfirm, Tooltip, Card } from 'ant-design-vue';
+ import { List, Popconfirm, Tooltip, Card, Tag } from 'ant-design-vue';
import { ClusterStateEnum, ExecModeEnum } from '/@/enums/flinkEnum';
import {
PauseCircleOutlined,
@@ -160,7 +160,13 @@
<div class="list-content-item">
<span>{{ t('setting.flinkCluster.form.executionMode') }}</span>
<p style="margin-top: 10px">
- {{ item.executionModeEnum.toLowerCase() }}
+ <Tag v-if="item.executionMode === ExecModeEnum.REMOTE" color="#2db7f5">REMOTE</Tag>
+ <Tag v-if="item.executionMode === ExecModeEnum.YARN_SESSION" color="#87d068"
+ >YARN SESSION</Tag
+ >
+ <Tag v-if="item.executionMode === ExecModeEnum.KUBERNETES_SESSION" color="#108ee9"
+ >KUBERNETES SESSION</Tag
+ >
</p>
</div>
</div>