YARN-5642. Typos in 9 log messages. Contributed by Mehran Hassani
This commit is contained in:
parent
fa80972efb
commit
20729ead91
|
@ -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);
|
||||||
|
|
|
@ -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;
|
||||||
|
|
|
@ -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"
|
||||||
|
|
|
@ -208,7 +208,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;
|
||||||
}
|
}
|
||||||
|
|
|
@ -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;
|
||||||
}
|
}
|
||||||
|
|
|
@ -237,7 +237,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" +
|
||||||
|
|
|
@ -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" +
|
||||||
|
|
|
@ -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;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue