diff --git a/flink-runtime-web/web-dashboard/src/app/interfaces/job-accumulators.ts b/flink-runtime-web/web-dashboard/src/app/interfaces/job-accumulators.ts index 758524b8c6df1c..5caee1366d2c21 100644 --- a/flink-runtime-web/web-dashboard/src/app/interfaces/job-accumulators.ts +++ b/flink-runtime-web/web-dashboard/src/app/interfaces/job-accumulators.ts @@ -32,6 +32,6 @@ export interface SubTaskAccumulators { type: string; value: string; subtask: number; - host: string; + endpoint: string; attempt: number; } diff --git a/flink-runtime-web/web-dashboard/src/app/interfaces/job-timeline.ts b/flink-runtime-web/web-dashboard/src/app/interfaces/job-timeline.ts index 7218e6ca15e079..01bcf4fad839a1 100644 --- a/flink-runtime-web/web-dashboard/src/app/interfaces/job-timeline.ts +++ b/flink-runtime-web/web-dashboard/src/app/interfaces/job-timeline.ts @@ -22,7 +22,7 @@ export interface JobSubTaskTime { now: number; subtasks: Array<{ subtask: number; - host: string; + endpoint: string; duration: number; timestamps: { CREATED: number; diff --git a/flink-runtime-web/web-dashboard/src/app/pages/job/overview/accumulators/job-overview-drawer-accumulators.component.html b/flink-runtime-web/web-dashboard/src/app/pages/job/overview/accumulators/job-overview-drawer-accumulators.component.html index 32280ef867534d..b6803e88887bf4 100644 --- a/flink-runtime-web/web-dashboard/src/app/pages/job/overview/accumulators/job-overview-drawer-accumulators.component.html +++ b/flink-runtime-web/web-dashboard/src/app/pages/job/overview/accumulators/job-overview-drawer-accumulators.component.html @@ -76,7 +76,7 @@ - ({{ subTaskAccumulator['subtask'] }}) {{ subTaskAccumulator.host }}, attempt: + ({{ subTaskAccumulator['subtask'] }}) {{ subTaskAccumulator.endpoint }}, attempt: {{ subTaskAccumulator.attempt + 1 }} {{ subTaskAccumulator.name }} diff --git a/flink-runtime-web/web-dashboard/src/app/pages/job/timeline/job-timeline.component.ts b/flink-runtime-web/web-dashboard/src/app/pages/job/timeline/job-timeline.component.ts index 7a77b7042f9edc..ed20b060731445 100644 --- a/flink-runtime-web/web-dashboard/src/app/pages/job/timeline/job-timeline.component.ts +++ b/flink-runtime-web/web-dashboard/src/app/pages/job/timeline/job-timeline.component.ts @@ -132,13 +132,13 @@ export class JobTimelineComponent implements AfterViewInit, OnDestroy { listOfTimeLine.forEach((item, index) => { if (index === listOfTimeLine.length - 1) { this.listOfSubTaskTimeLine.push({ - name: `${task.subtask} - ${task.host}`, + name: `${task.subtask} - ${task.endpoint}`, status: item.status, range: [item.startTime, task.duration + listOfTimeLine[0].startTime] }); } else { this.listOfSubTaskTimeLine.push({ - name: `${task.subtask} - ${task.host}`, + name: `${task.subtask} - ${task.endpoint}`, status: item.status, range: [item.startTime, listOfTimeLine[index + 1].startTime] });