[flink] branch master updated: [FLINK-17012][webui] Added support of RECOVERING state

[pnowojski]

This is an automated email from the ASF dual-hosted git repository.

pnowojski 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 61b8c55  [FLINK-17012][webui] Added support of RECOVERING state
61b8c55 is described below

commit 61b8c5578e830fe6287893460762e72bb3f1e6fc
Author: Anton Kalashnikov <kaa....@yandex.ru>
AuthorDate: Thu Apr 1 12:11:17 2021 +0200

    [FLINK-17012][webui] Added support of RECOVERING state
---
 flink-runtime-web/web-dashboard/src/app/app.config.ts                  | 3 ++-
 flink-runtime-web/web-dashboard/src/app/interfaces/job-detail.ts       | 1 +
 flink-runtime-web/web-dashboard/src/app/interfaces/job-overview.ts     | 1 +
 .../web-dashboard/src/app/interfaces/job-vertex-task-manager.ts        | 1 +
 4 files changed, 5 insertions(+), 1 deletion(-)

diff --git a/flink-runtime-web/web-dashboard/src/app/app.config.ts 
b/flink-runtime-web/web-dashboard/src/app/app.config.ts
index 97a5c83..e4e2c7b 100644
--- a/flink-runtime-web/web-dashboard/src/app/app.config.ts
+++ b/flink-runtime-web/web-dashboard/src/app/app.config.ts
@@ -31,6 +31,7 @@ export const COLOR_MAP = {
   SCHEDULED: '#722ed1',
   COMPLETED: '#1890ff',
   RESTARTING: '#13c2c2',
-  INITIALIZING: '#738df8'
+  INITIALIZING: '#738df8',
+  RECOVERING: '#18c98b'
 };
 export const LONG_MIN_VALUE = -9223372036854776000;
diff --git a/flink-runtime-web/web-dashboard/src/app/interfaces/job-detail.ts 
b/flink-runtime-web/web-dashboard/src/app/interfaces/job-detail.ts
index 1fe96f2..4483a41 100644
--- a/flink-runtime-web/web-dashboard/src/app/interfaces/job-detail.ts
+++ b/flink-runtime-web/web-dashboard/src/app/interfaces/job-detail.ts
@@ -104,6 +104,7 @@ interface TasksStatus {
   FAILED: number;
   RECONCILING: number;
   CANCELING: number;
+  RECOVERING: number;
 }
 
 interface MetricsStatus {
diff --git a/flink-runtime-web/web-dashboard/src/app/interfaces/job-overview.ts 
b/flink-runtime-web/web-dashboard/src/app/interfaces/job-overview.ts
index 9dff644..05e93d6 100644
--- a/flink-runtime-web/web-dashboard/src/app/interfaces/job-overview.ts
+++ b/flink-runtime-web/web-dashboard/src/app/interfaces/job-overview.ts
@@ -43,4 +43,5 @@ export interface TaskStatusInterface {
   RUNNING: number;
   SCHEDULED: number;
   TOTAL: number;
+  RECOVERING: number;
 }
diff --git 
a/flink-runtime-web/web-dashboard/src/app/interfaces/job-vertex-task-manager.ts 
b/flink-runtime-web/web-dashboard/src/app/interfaces/job-vertex-task-manager.ts
index 91f7e98..6f3e104 100644
--- 
a/flink-runtime-web/web-dashboard/src/app/interfaces/job-vertex-task-manager.ts
+++ 
b/flink-runtime-web/web-dashboard/src/app/interfaces/job-vertex-task-manager.ts
@@ -49,6 +49,7 @@ export interface VertexTaskManagerDetailInterface {
     RECONCILING: number;
     RUNNING: number;
     SCHEDULED: number;
+    RECOVERING: number;
   };
   'taskmanager-id': string;
 }