diff --git a/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/scheduler/ResourceSchedulerWrapper.java b/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/scheduler/ResourceSchedulerWrapper.java index e729363..9662113 100644 --- a/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/scheduler/ResourceSchedulerWrapper.java +++ b/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/scheduler/ResourceSchedulerWrapper.java @@ -703,11 +703,12 @@ public MetricsLogRunnable() { @Override public void run() { - if(running) { - // all WebApp to get real tracking json - String metrics = web.generateRealTimeTrackingMetrics(); - // output + if(running && queueSet != null) { try { + // all WebApp to get real tracking json + String metrics = web.generateRealTimeTrackingMetrics(); + + // output if(firstLine) { metricsLogBW.write(metrics + EOL); firstLine = false; @@ -715,7 +716,7 @@ public void run() { metricsLogBW.write("," + metrics + EOL); } metricsLogBW.flush(); - } catch (IOException e) { + } catch (Exception e) { e.printStackTrace(); } }