Skip to content

Commit de5f2b9

Browse files
committed
[FLINK-38899][runtime-web] Introduce the Rescales/History sub-page for streaming jobs with the adaptive scheduler enabled - Temporary commit for review (Changed the refresh function)
1 parent 3824aab commit de5f2b9

2 files changed

Lines changed: 3 additions & 9 deletions

File tree

flink-runtime-web/web-dashboard/src/app/pages/job/rescales/job-rescales.component.html

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@
2121
[nzSize]="'small'"
2222
[nzAnimated]="{ inkBar: true, tabPane: false }"
2323
[nzTabBarExtraContent]="extraTemplate"
24-
(nzSelectedIndexChange)="onTabChange($event)"
24+
(nzSelectedIndexChange)="refresh()"
2525
>
2626
<nz-tab nzTitle="History">
2727
<nz-table
@@ -217,7 +217,7 @@ <h3><strong>Rescale Details</strong></h3>
217217
{{ truncateName(vertex.value.jobVertexName) }}
218218
</td>
219219
<td>{{ vertex.value.preRescaleParallelism }}</td>
220-
<td>{{ vertex.value.postRescaleParallelism }}</td>
220+
<td>{{ vertex.value.postRescaleParallelism || '-' }}</td>
221221
<td>{{ vertex.value.desiredParallelism }}</td>
222222
<td>{{ vertex.value.sufficientParallelism }}</td>
223223
<td nz-tooltip [nzTooltipTitle]="vertex.value.slotSharingGroupId">
@@ -295,7 +295,7 @@ <h3><strong>Rescale Details</strong></h3>
295295
</td>
296296
<td>{{ slot.value.slotSharingGroupName }}</td>
297297
<td>{{ slot.value.preRescaleSlots }}</td>
298-
<td>{{ slot.value.postRescaleSlots }}</td>
298+
<td>{{ slot.value.postRescaleSlots || '-' }}</td>
299299
<td>{{ slot.value.desiredSlots }}</td>
300300
<td>{{ slot.value.minimalRequiredSlots }}</td>
301301
<td>

flink-runtime-web/web-dashboard/src/app/pages/job/rescales/job-rescales.component.ts

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -130,12 +130,6 @@ export class JobRescalesComponent implements OnInit, OnDestroy {
130130
this.refresh$.next();
131131
}
132132

133-
public onTabChange(index: number): void {
134-
if (index === 0) {
135-
this.refresh$.next();
136-
}
137-
}
138-
139133
public trackById(item: BriefJobRescaleDetails): string {
140134
return item.rescaleUuid;
141135
}

0 commit comments

Comments
 (0)