You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ta...@apache.org on 2022/06/20 07:25:51 UTC
[flink] branch release-1.15 updated: [FLINK-27734][runtime-web] fix checkpoint interval in WebUI
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 <wa...@meituan.com>
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;