diff --git a/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/scheduler/SLSCapacityScheduler.java b/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/scheduler/SLSCapacityScheduler.java index f34a3d3fc65..a3182042f84 100644 --- a/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/scheduler/SLSCapacityScheduler.java +++ b/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/scheduler/SLSCapacityScheduler.java @@ -119,6 +119,9 @@ public Allocation allocate(ApplicationAttemptId attemptId, containerIds, strings, strings2, updateRequests); return allocation; + } catch (Exception e) { + LOG.error("Caught exception from allocate", e); + throw e; } finally { context.stop(); schedulerMetrics.increaseSchedulerAllocationCounter(); diff --git a/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/scheduler/SLSFairScheduler.java b/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/scheduler/SLSFairScheduler.java index 09ef2cf9035..c8324368444 100644 --- a/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/scheduler/SLSFairScheduler.java +++ b/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/scheduler/SLSFairScheduler.java @@ -111,6 +111,9 @@ public Allocation allocate(ApplicationAttemptId attemptId, schedulingRequests, containerIds, blacklistAdditions, blacklistRemovals, updateRequests); return allocation; + } catch (Exception e) { + LOG.error("Caught exception from allocate", e); + throw e; } finally { context.stop(); schedulerMetrics.increaseSchedulerAllocationCounter();