This is an automated email from the ASF dual-hosted git repository.
tangyun pushed a commit to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.15 by this push:
new efee7405c3a [FLINK-27734][runtime-web] fix checkpoint interval in WebUI
efee7405c3a is described below
commit efee7405c3acf54bf2cc79b676cb881ac5f2c362
Author: wangfeifan <[email protected]>
AuthorDate: Mon May 23 00:08:23 2022 +0800
[FLINK-27734][runtime-web] fix checkpoint interval in WebUI
---
.../src/app/pages/job/checkpoints/job-checkpoints.component.html | 4 ++--
.../src/app/pages/job/checkpoints/job-checkpoints.component.ts | 2 ++
2 files changed, 4 insertions(+), 2 deletions(-)
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 6c110ce488d..0951cfc66df 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 05eb1b49e4d..2c5d9a6b092 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 @@ import { JobService } from 'services';
changeDetection: ChangeDetectionStrategy.OnPush
})
export class JobCheckpointsComponent implements OnInit {
+ disabledInterval = 0x7fffffffffffffff;
+
public readonly trackById = (_: number, node: CheckpointHistory): number =>
node.id;
public checkPointStats: Checkpoint;