diff --git a/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/scheduler/SchedulerMetrics.java b/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/scheduler/SchedulerMetrics.java index b8bc8be..ffd6489 100644 --- a/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/scheduler/SchedulerMetrics.java +++ b/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/scheduler/SchedulerMetrics.java @@ -518,11 +518,12 @@ public void run() { @Override public void run() { - if(running) { - // all WebApp to get real tracking json - String trackingMetrics = web.generateRealTimeTrackingMetrics(); - // output + SchedulerWrapper wrapper = (SchedulerWrapper) scheduler; + if(running && wrapper.getTracker().getQueueSet() != null) { try { + // all WebApp to get real tracking json + String trackingMetrics = web.generateRealTimeTrackingMetrics(); + // output if(firstLine) { metricsLogBW.write(trackingMetrics + EOL); firstLine = false; @@ -530,8 +531,8 @@ public void run() { metricsLogBW.write("," + trackingMetrics + EOL); } metricsLogBW.flush(); - } catch (IOException e) { - LOG.info(e.getMessage()); + } catch (Exception e) { + LOG.warn("Failed to output metircs ", e); } } }