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;

Reply via email to