diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/CapacityScheduler.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/CapacityScheduler.java index f1d0f9c..8c0b0c1 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/CapacityScheduler.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/CapacityScheduler.java @@ -838,7 +838,10 @@ private synchronized void doneApplicationAttempt( applications.get(applicationAttemptId.getApplicationId()); if (application == null || attempt == null) { - LOG.info("Unknown application " + applicationAttemptId + " has completed!"); + if (LOG.isDebugEnabled()) { + LOG.debug("Unknown application " + applicationAttemptId + + " has completed!"); + } return; } @@ -1427,8 +1430,10 @@ private synchronized void removeNode(RMNode nodeInfo) { protected synchronized void completedContainer(RMContainer rmContainer, ContainerStatus containerStatus, RMContainerEventType event) { if (rmContainer == null) { - LOG.info("Container " + containerStatus.getContainerId() + - " completed with event " + event); + if (LOG.isDebugEnabled()) { + LOG.debug("Container " + containerStatus.getContainerId() + + " completed with event " + event); + } return; } @@ -1440,8 +1445,10 @@ protected synchronized void completedContainer(RMContainer rmContainer, ApplicationId appId = container.getId().getApplicationAttemptId().getApplicationId(); if (application == null) { - LOG.info("Container " + container + " of" + " finished application " - + appId + " completed with event " + event); + if (LOG.isDebugEnabled()) { + LOG.debug("Container " + container + " of finished application " + + appId + " completed with event " + event); + } return; } diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FairScheduler.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FairScheduler.java index 2ed3b2a..612e4fc 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FairScheduler.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FairScheduler.java @@ -754,7 +754,10 @@ private synchronized void removeApplicationAttempt( FSAppAttempt attempt = getSchedulerApp(applicationAttemptId); if (attempt == null || application == null) { - LOG.info("Unknown application " + applicationAttemptId + " has completed!"); + if (LOG.isDebugEnabled()) { + LOG.debug("Unknown application " + applicationAttemptId + + " has completed!"); + } return; } @@ -806,8 +809,10 @@ private synchronized void removeApplicationAttempt( protected synchronized void completedContainer(RMContainer rmContainer, ContainerStatus containerStatus, RMContainerEventType event) { if (rmContainer == null) { - LOG.info("Container " + containerStatus.getContainerId() - + " completed with event " + event); + if (LOG.isDebugEnabled()) { + LOG.debug("Container " + containerStatus.getContainerId() + + " completed with event " + event); + } return; } @@ -819,9 +824,10 @@ protected synchronized void completedContainer(RMContainer rmContainer, ApplicationId appId = container.getId().getApplicationAttemptId().getApplicationId(); if (application == null) { - LOG.info("Container " + container + " of" + - " finished application " + appId + - " completed with event " + event); + if (LOG.isDebugEnabled()) { + LOG.debug("Container " + container + " of finished application " + + appId + " completed with event " + event); + } return; }