This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a commit to branch release-1.13
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.13 by this push:
new dbcbb98 [FLINK-22301][runtime] Statebackend and CheckpointStorage
type is not shown in the Web UI
dbcbb98 is described below
commit dbcbb984d5018ddee6638363ad5871d677a0bd80
Author: SteNicholas <[email protected]>
AuthorDate: Fri Apr 23 17:28:06 2021 +0800
[FLINK-22301][runtime] Statebackend and CheckpointStorage type is not shown
in the Web UI
[FLINK-22301][runtime] Statebackend and CheckpointStorage type is not shown
in the Web UI
This closes #15732.
---
.../web-dashboard/src/app/interfaces/job-checkpoint.ts | 2 ++
.../src/app/pages/job/checkpoints/job-checkpoints.component.html | 8 ++++++++
2 files changed, 10 insertions(+)
diff --git
a/flink-runtime-web/web-dashboard/src/app/interfaces/job-checkpoint.ts
b/flink-runtime-web/web-dashboard/src/app/interfaces/job-checkpoint.ts
index 5fc6d7e..6fbbe47 100644
--- a/flink-runtime-web/web-dashboard/src/app/interfaces/job-checkpoint.ts
+++ b/flink-runtime-web/web-dashboard/src/app/interfaces/job-checkpoint.ts
@@ -115,6 +115,8 @@ export interface CheckPointConfigInterface {
enabled: boolean;
delete_on_cancellation: boolean;
};
+ state_backend: string;
+ checkpoint_storage: string;
unaligned_checkpoints: boolean;
tolerable_failed_checkpoints: number;
}
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 e40eab8..275b53c 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
@@ -224,6 +224,14 @@
<td *ngIf="checkPointConfig['mode'] != 'exactly_once'">At Least
Once</td>
</tr>
<tr>
+ <td>Checkpoint Storage</td>
+ <td>{{ checkPointConfig['checkpoint_storage'] }}</td>
+ </tr>
+ <tr>
+ <td>State Backend</td>
+ <td>{{ checkPointConfig['state_backend'] }}</td>
+ </tr>
+ <tr>
<td>Interval</td>
<td *ngIf="checkPointConfig['interval'] ==
'0x7fffffffffffffff'">Periodic checkpoints disabled</td>
<td *ngIf="checkPointConfig['interval'] !=
'0x7fffffffffffffff'">{{ checkPointConfig['interval'] | humanizeDuration}}</td>
