diff --git a/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/scheduler/SLSSchedulerCommons.java b/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/scheduler/SLSSchedulerCommons.java index a99fe53eff..d743cc52c7 100644 --- a/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/scheduler/SLSSchedulerCommons.java +++ b/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/scheduler/SLSSchedulerCommons.java @@ -249,6 +249,8 @@ public void handle(SchedulerEvent schedulerEvent) { schedulerEvent.getType()).time(); ((SchedulerWrapper)scheduler).propagatedHandle(schedulerEvent); + } catch (Exception e) { + LOG.error("Caught exception while handling scheduler event", e); } finally { if (handlerTimer != null) { handlerTimer.stop(); 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 a1e530a6f7..85f50e2e76 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 @@ -178,7 +178,7 @@ void init(ResourceScheduler resourceScheduler, Configuration config) pool.scheduleAtFixedRate(new HistogramsRunnable(), 0, 1000, TimeUnit.MILLISECONDS); - // a thread to output metrics for real-tiem tracking + // a thread to output metrics for real-time tracking pool.scheduleAtFixedRate(new MetricsLogRunnable(), 0, 1000, TimeUnit.MILLISECONDS); @@ -255,6 +255,8 @@ public void trackQueue(String queue) { trackedQueues.add(queue); registerQueueMetrics(queue); } + } catch (Exception e) { + LOG.error("Caught exception from track a queue", e); } finally { queueLock.unlock(); } @@ -467,6 +469,8 @@ private void registerSchedulerMetrics() { schedulerHistogramList.add(histogram); histogramTimerMap.put(histogram, schedulerHandleTimerMap.get(e)); } + } catch(Exception e) { + LOG.error("Caught exception during register scheduler metrics", e); } finally { samplerLock.unlock(); } @@ -510,6 +514,8 @@ public Integer getValue() { } ); } + } catch(Exception e){ + LOG.error("Caught exception from register node usage memory", e); } finally { samplerLock.unlock(); }