Class JobFailureMetricReporter


  • public class JobFailureMetricReporter
    extends Object
    Helper class to simplify job failure reporting through a metric group.
    • Constructor Detail

      • JobFailureMetricReporter

        public JobFailureMetricReporter​(MetricGroup metricGroup)
    • Method Detail

      • reportJobFailure

        public void reportJobFailure​(org.apache.flink.runtime.scheduler.adaptive.FailureResult failureHandlingResult,
                                     Map<String,​String> failureLabels)