big-data/hadoop
big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Projects Wiki Activity

YARN-600. Hook up cgroups CPU settings to the number of virtual cores allocated. (sandyr via tucu)

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/trunk@1492365 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Alejandro Abdelnur 2013-06-12 18:57:31 +00:00
parent b090bc1c21
commit 80eb92aff0
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hadoop-yarn-project/CHANGES.txt
View File

@ -315,6 +315,9 @@ Release 2.1.0-beta - UNRELEASED
YARN-731. RPCUtil.unwrapAndThrowException should unwrap remote YARN-731. RPCUtil.unwrapAndThrowException should unwrap remote
RuntimeExceptions. (Zhijie Shen via sseth) RuntimeExceptions. (Zhijie Shen via sseth)
YARN-600. Hook up cgroups CPU settings to the number of virtual cores
allocated. (sandyr via tucu)
OPTIMIZATIONS OPTIMIZATIONS
YARN-512. Log aggregation root directory check is more expensive than it YARN-512. Log aggregation root directory check is more expensive than it

7
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/util/CgroupsLCEResourcesHandler.java
View File

@ -172,18 +172,15 @@ public class CgroupsLCEResourcesHandler implements LCEResourcesHandler {
* Next three functions operate on all the resources we are enforcing. * Next three functions operate on all the resources we are enforcing.
*/ */
/*
* TODO: After YARN-2 is committed, we should call containerResource.getCpus()
* (or equivalent) to multiply the weight by the number of requested cpus.
*/
private void setupLimits(ContainerId containerId, private void setupLimits(ContainerId containerId,
Resource containerResource) throws IOException { Resource containerResource) throws IOException {
String containerName = containerId.toString(); String containerName = containerId.toString();
if (isCpuWeightEnabled()) { if (isCpuWeightEnabled()) {
createCgroup(CONTROLLER_CPU, containerName); createCgroup(CONTROLLER_CPU, containerName);
int cpuShares = CPU_DEFAULT_WEIGHT * containerResource.getVirtualCores();
updateCgroup(CONTROLLER_CPU, containerName, "shares", updateCgroup(CONTROLLER_CPU, containerName, "shares",
String.valueOf(CPU_DEFAULT_WEIGHT)); String.valueOf(cpuShares));
} }
} }