| commit | efee7405c3acf54bf2cc79b676cb881ac5f2c362 | [log] [tgz] |
|---|---|---|
| author | wangfeifan <wangfeifan@meituan.com> | Mon May 23 00:08:23 2022 +0800 |
| committer | Yun Tang <myasuka@live.com> | Mon Jun 20 15:25:41 2022 +0800 |
| tree | d1feebd447911173548b0fc31a2acfc21795967d | |
| parent | 921b608158288bc807493e1c425f6d7ec6f47b18 [diff] |
[FLINK-27734][runtime-web] fix checkpoint interval in WebUI
diff --git a/flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/job-checkpoints.component.html b/flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/job-checkpoints.component.html index 6c110ce..0951cfc 100644 --- a/flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/job-checkpoints.component.html +++ b/flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/job-checkpoints.component.html
@@ -500,10 +500,10 @@ </tr> <tr> <td>Interval</td> - <td *ngIf="checkPointConfig['interval'] === '0x7fffffffffffffff'"> + <td *ngIf="checkPointConfig['interval'] === disabledInterval"> Periodic checkpoints disabled </td> - <td *ngIf="checkPointConfig['interval'] !== '0x7fffffffffffffff'"> + <td *ngIf="checkPointConfig['interval'] !== disabledInterval"> {{ checkPointConfig['interval'] | humanizeDuration }} </td> </tr>
diff --git a/flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/job-checkpoints.component.ts b/flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/job-checkpoints.component.ts index 05eb1b4..2c5d9a6 100644 --- a/flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/job-checkpoints.component.ts +++ b/flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/job-checkpoints.component.ts
@@ -29,6 +29,8 @@ changeDetection: ChangeDetectionStrategy.OnPush }) export class JobCheckpointsComponent implements OnInit { + disabledInterval = 0x7fffffffffffffff; + public readonly trackById = (_: number, node: CheckpointHistory): number => node.id; public checkPointStats: Checkpoint;