[FLINK-13386][web]: Fix operators/tasks metrics sort

spotify · Sep 27, 2019 · 0078e7a · 0078e7a
1 parent fe254a3
commit 0078e7a
Showing 1 changed file with 17 additions and 3 deletions.
diff --git a/flink-runtime-web/web-dashboard/src/app/services/metrics.service.ts b/flink-runtime-web/web-dashboard/src/app/services/metrics.service.ts
@@ -33,9 +33,23 @@ export class MetricsService {
  * @param vertexId
  */
  getAllAvailableMetrics(jobId: string, vertexId: string) {
- return this.httpClient.get<Array<{ id: string; value: string }>>(
- `${BASE_URL}/jobs/${jobId}/vertices/${vertexId}/metrics`
- );
+ return this.httpClient
+ .get<Array<{ id: string; value: string }>>(`${BASE_URL}/jobs/${jobId}/vertices/${vertexId}/metrics`)
+ .pipe(
+ map(item =>
+ item.sort((pre, next) => {
+ const preId = pre.id.toLowerCase();
+ const nextId = next.id.toLowerCase();
+ if (preId < nextId) {
+ return -1;
+ } else if (preId > nextId) {
+ return 1;
+ } else {
+ return 0;
+ }
+ })
+ )
+ );
  }
 
  /**