flink-runtime-web/web-dashboard/src/app/pages/job/exceptions/job-exceptions.component.ts

/*
 *   Licensed to the Apache Software Foundation (ASF) under one
 *   or more contributor license agreements.  See the NOTICE file
 *   distributed with this work for additional information
 *   regarding copyright ownership.  The ASF licenses this file
 *   to you under the Apache License, Version 2.0 (the
 *   "License"); you may not use this file except in compliance
 *   with the License.  You may obtain a copy of the License at
 *       http://www.apache.org/licenses/LICENSE-2.0
 *   Unless required by applicable law or agreed to in writing, software
 *   distributed under the License is distributed on an "AS IS" BASIS,
 *   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 *   See the License for the specific language governing permissions and
 *   limitations under the License.
 */

import { formatDate } from '@angular/common';
import { Component, OnInit, ChangeDetectionStrategy, ChangeDetectorRef } from '@angular/core';
import { first, flatMap } from 'rxjs/operators';
import { ConfigService, JobService } from 'flink-services';

@Component({
  selector       : 'flink-job-exceptions',
  templateUrl    : './job-exceptions.component.html',
  changeDetection: ChangeDetectionStrategy.OnPush,
  styleUrls      : [ './job-exceptions.component.less' ]
})
export class JobExceptionsComponent implements OnInit {
  rootException = '';
  listOfException = [];

  trackExceptionBy(index, node) {
    return node.id;
  }

  constructor(public configService: ConfigService, private jobService: JobService, private cdr: ChangeDetectorRef) {
  }

  ngOnInit() {
    this.jobService.jobDetail$.pipe(
      first(),
      flatMap(() => this.jobService.loadExceptions(this.jobService.jobDetail.jid))
    ).subscribe(data => {
      // @ts-ignore
      if (data[ 'root-exception' ]) {
        this.rootException = formatDate(data.timestamp, 'yyyy-MM-dd HH:mm:ss', 'en') + '\n' + data[ 'root-exception' ];
      } else {
        this.rootException = 'No Root Exception';
      }
      this.listOfException = data[ 'all-exceptions' ];
      this.cdr.markForCheck();
    });
  }

}