This is an automated email from the ASF dual-hosted git repository.
tangyun pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 18c13fe4b67 [FLINK-27734][runtime-web] fix checkpoint interval in WebUI
18c13fe4b67 is described below
commit 18c13fe4b6788e3ec8af95551ebe3e598b32df61
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 8a8f3c487c0..fd536519932 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 2e10225147a..09a5f41cf39 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
@@ -32,6 +32,8 @@ import { JobLocalService } from '../job-local.service';
changeDetection: ChangeDetectionStrategy.OnPush
})
export class JobCheckpointsComponent implements OnInit, OnDestroy {
+ disabledInterval = 0x7fffffffffffffff;
+
public readonly trackById = (_: number, node: CheckpointHistory): number =>
node.id;
public checkPointStats?: Checkpoint;