feature(web): 增加 runtime 信息展示
This commit is contained in:
@@ -389,6 +389,23 @@ function flinkJobProperty(id, name, runMode) {
|
||||
}
|
||||
}
|
||||
|
||||
function runMetaProperty(runMode) {
|
||||
return {
|
||||
type: 'property',
|
||||
title: `${runMode} 运行时信息`,
|
||||
items: [
|
||||
{label: '运行集群', content: `\${${runMode}Runtime.cluster}`},
|
||||
{label: '运行主机', content: copyField(`${runMode}Runtime.host`)},
|
||||
{label: '进程', content: copyField(`${runMode}Runtime.jvmPid`)},
|
||||
{label: '任务 ID', content: copyField(`${runMode}Runtime.applicationId`), span: 2},
|
||||
{label: 'Jar 版本', content: `\${${runMode}Runtime.executorVersion}`},
|
||||
{label: '任务名称', content: `\${${runMode}Runtime.flinkJobName}`},
|
||||
{label: '容器 ID', content: `\${${runMode}Runtime.containerId}`, span: 2},
|
||||
{label: '容器路径', content: copyField(`${runMode}Runtime.containerPath`, undefined, 120), span: 3},
|
||||
]
|
||||
}
|
||||
}
|
||||
|
||||
function flinkJobDialog() {
|
||||
return {
|
||||
title: 'Flink job 详情',
|
||||
@@ -497,16 +514,20 @@ function tableMetaDialog() {
|
||||
},
|
||||
{
|
||||
type: 'button-group',
|
||||
tiled: true,
|
||||
tiled: false,
|
||||
buttons: [
|
||||
{
|
||||
disabledOn: '${!syncRunning}',
|
||||
disabledTip: '同步未运行',
|
||||
label: '同步情况',
|
||||
type: 'action',
|
||||
type: 'button',
|
||||
icon: 'fa fa-arrows-rotate',
|
||||
actionType: 'dialog',
|
||||
dialog: simpleYarnDialog('b5-sync', '同步详情', 'syncJobName')
|
||||
},
|
||||
{
|
||||
disabledOn: '${!compactionRunning}',
|
||||
disabledTip: '压缩未运行',
|
||||
label: '压缩情况',
|
||||
type: 'action',
|
||||
icon: 'fa fa-minimize',
|
||||
@@ -797,6 +818,16 @@ function tableMetaDialog() {
|
||||
},
|
||||
]
|
||||
},
|
||||
{type: 'divider', visibleOn: '${syncRuntime}'},
|
||||
{
|
||||
visibleOn: '${syncRuntime}',
|
||||
...runMetaProperty('sync'),
|
||||
},
|
||||
{type: 'divider', visibleOn: '${compactionRuntime}'},
|
||||
{
|
||||
visibleOn: '${compactionRuntime}',
|
||||
...runMetaProperty('compaction'),
|
||||
},
|
||||
{type: 'divider'},
|
||||
flinkJobProperty('flinkJobId', 'flinkJob.name', 'flinkJob.runMode'),
|
||||
{type: 'divider'},
|
||||
|
||||
Reference in New Issue
Block a user