YARN-5642. Typos in 9 log messages. Contributed by Mehran Hassani

This commit is contained in:
Naganarasimha 2016-09-17 10:35:39 +05:30
parent 7d21c280a8
commit 4174b9756c
8 changed files with 9 additions and 9 deletions

View File

@ -142,7 +142,7 @@ public class AsyncDispatcher extends AbstractService implements Dispatcher {
protected void serviceStop() throws Exception { protected void serviceStop() throws Exception {
if (drainEventsOnStop) { if (drainEventsOnStop) {
blockNewEvents = true; blockNewEvents = true;
LOG.info("AsyncDispatcher is draining to stop, igonring any new events."); LOG.info("AsyncDispatcher is draining to stop, ignoring any new events.");
long endTime = System.currentTimeMillis() + getConfig() long endTime = System.currentTimeMillis() + getConfig()
.getLong(YarnConfiguration.DISPATCHER_DRAIN_EVENTS_TIMEOUT, .getLong(YarnConfiguration.DISPATCHER_DRAIN_EVENTS_TIMEOUT,
YarnConfiguration.DEFAULT_DISPATCHER_DRAIN_EVENTS_TIMEOUT); YarnConfiguration.DEFAULT_DISPATCHER_DRAIN_EVENTS_TIMEOUT);

View File

@ -54,7 +54,7 @@ public abstract class YarnAuthorizationProvider {
(YarnAuthorizationProvider) ReflectionUtils.newInstance( (YarnAuthorizationProvider) ReflectionUtils.newInstance(
authorizerClass, conf); authorizerClass, conf);
authorizer.init(conf); authorizer.init(conf);
LOG.info(authorizerClass.getName() + " is instiantiated."); LOG.info(authorizerClass.getName() + " is instantiated.");
} }
} }
return authorizer; return authorizer;

View File

@ -405,7 +405,7 @@ public class FileSystemApplicationHistoryStore extends AbstractService
} }
} }
} }
LOG.info("Completed reading history information of all conatiners" LOG.info("Completed reading history information of all containers"
+ " of application attempt " + appAttemptId); + " of application attempt " + appAttemptId);
} catch (IOException e) { } catch (IOException e) {
LOG.info("Error when reading history information of some containers" LOG.info("Error when reading history information of some containers"

View File

@ -216,7 +216,7 @@ public class ContainersMonitorImpl extends AbstractService implements
return false; return false;
} }
if (!(isPmemCheckEnabled() || isVmemCheckEnabled())) { if (!(isPmemCheckEnabled() || isVmemCheckEnabled())) {
LOG.info("Neither virutal-memory nor physical-memory monitoring is " + LOG.info("Neither virtual-memory nor physical-memory monitoring is " +
"needed. Not running the monitor-thread"); "needed. Not running the monitor-thread");
return false; return false;
} }

View File

@ -415,7 +415,7 @@ public abstract class AbstractReservationSystem extends AbstractService
minAllocation, maxAllocation, planQueueName, minAllocation, maxAllocation, planQueueName,
getReplanner(planQueuePath), getReservationSchedulerConfiguration() getReplanner(planQueuePath), getReservationSchedulerConfiguration()
.getMoveOnExpiry(planQueuePath), rmContext); .getMoveOnExpiry(planQueuePath), rmContext);
LOG.info("Intialized plan {} based on reservable queue {}", LOG.info("Initialized plan {} based on reservable queue {}",
plan.toString(), planQueueName); plan.toString(), planQueueName);
return plan; return plan;
} }

View File

@ -230,7 +230,7 @@ public class LeafQueue extends AbstractCSQueue {
LOG.info("Initializing " + queueName + "\n" + LOG.info("Initializing " + queueName + "\n" +
"capacity = " + queueCapacities.getCapacity() + "capacity = " + queueCapacities.getCapacity() +
" [= (float) configuredCapacity / 100 ]" + "\n" + " [= (float) configuredCapacity / 100 ]" + "\n" +
"asboluteCapacity = " + queueCapacities.getAbsoluteCapacity() + "absoluteCapacity = " + queueCapacities.getAbsoluteCapacity() +
" [= parentAbsoluteCapacity * capacity ]" + "\n" + " [= parentAbsoluteCapacity * capacity ]" + "\n" +
"maxCapacity = " + queueCapacities.getMaximumCapacity() + "maxCapacity = " + queueCapacities.getMaximumCapacity() +
" [= configuredMaxCapacity ]" + "\n" + " [= configuredMaxCapacity ]" + "\n" +

View File

@ -125,9 +125,9 @@ public class ParentQueue extends AbstractCSQueue {
LOG.info(queueName + LOG.info(queueName +
", capacity=" + this.queueCapacities.getCapacity() + ", capacity=" + this.queueCapacities.getCapacity() +
", asboluteCapacity=" + this.queueCapacities.getAbsoluteCapacity() + ", absoluteCapacity=" + this.queueCapacities.getAbsoluteCapacity() +
", maxCapacity=" + this.queueCapacities.getMaximumCapacity() + ", maxCapacity=" + this.queueCapacities.getMaximumCapacity() +
", asboluteMaxCapacity=" + this.queueCapacities.getAbsoluteMaximumCapacity() + ", absoluteMaxCapacity=" + this.queueCapacities.getAbsoluteMaximumCapacity() +
", state=" + state + ", state=" + state +
", acls=" + aclsString + ", acls=" + aclsString +
", labels=" + labelStrBuilder.toString() + "\n" + ", labels=" + labelStrBuilder.toString() + "\n" +

View File

@ -944,7 +944,7 @@ public class FairScheduler extends
FSAppAttempt application = getSchedulerApp(appAttemptId); FSAppAttempt application = getSchedulerApp(appAttemptId);
if (application == null) { if (application == null) {
LOG.info("Calling allocate on removed " + LOG.info("Calling allocate on removed " +
"or non existant application " + appAttemptId); "or non existent application " + appAttemptId);
return EMPTY_ALLOCATION; return EMPTY_ALLOCATION;
} }