You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by ka...@apache.org on 2015/04/01 02:34:57 UTC
hadoop git commit: YARN-3428. Debug log resources to be localized for
a container. (kasha)
Repository: hadoop
Updated Branches:
refs/heads/trunk 7610925e9 -> 2daa478a6
YARN-3428. Debug log resources to be localized for a container. (kasha)
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/2daa478a
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/2daa478a
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/2daa478a
Branch: refs/heads/trunk
Commit: 2daa478a6420585dc13cea2111580ed5fe347bc1
Parents: 7610925
Author: Karthik Kambatla <ka...@apache.org>
Authored: Tue Mar 31 17:34:40 2015 -0700
Committer: Karthik Kambatla <ka...@apache.org>
Committed: Tue Mar 31 17:34:47 2015 -0700
----------------------------------------------------------------------
hadoop-yarn-project/CHANGES.txt | 2 ++
.../localizer/ResourceLocalizationService.java | 12 ++++++++++--
2 files changed, 12 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hadoop/blob/2daa478a/hadoop-yarn-project/CHANGES.txt
----------------------------------------------------------------------
diff --git a/hadoop-yarn-project/CHANGES.txt b/hadoop-yarn-project/CHANGES.txt
index ada7ed7..f6093e2 100644
--- a/hadoop-yarn-project/CHANGES.txt
+++ b/hadoop-yarn-project/CHANGES.txt
@@ -89,6 +89,8 @@ Release 2.8.0 - UNRELEASED
YARN-3258. FairScheduler: Need to add more logging to investigate
allocations. (Anubhav Dhoot via ozawa)
+ YARN-3428. Debug log resources to be localized for a container. (kasha)
+
OPTIMIZATIONS
YARN-3339. TestDockerContainerExecutor should pull a single image and not
http://git-wip-us.apache.org/repos/asf/hadoop/blob/2daa478a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/localizer/ResourceLocalizationService.java
----------------------------------------------------------------------
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/localizer/ResourceLocalizationService.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/localizer/ResourceLocalizationService.java
index dd50ead..4236392 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/localizer/ResourceLocalizationService.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/localizer/ResourceLocalizationService.java
@@ -448,6 +448,10 @@ public class ResourceLocalizationService extends CompositeService
.getApplicationId());
for (LocalResourceRequest req : e.getValue()) {
tracker.handle(new ResourceRequestEvent(req, e.getKey(), ctxt));
+ if (LOG.isDebugEnabled()) {
+ LOG.debug("Localizing " + req.getPath() +
+ " for container " + c.getContainerId());
+ }
}
}
}
@@ -456,10 +460,14 @@ public class ResourceLocalizationService extends CompositeService
ResourceRetentionSet retain =
new ResourceRetentionSet(delService, cacheTargetSize);
retain.addResources(publicRsrc);
- LOG.debug("Resource cleanup (public) " + retain);
+ if (LOG.isDebugEnabled()) {
+ LOG.debug("Resource cleanup (public) " + retain);
+ }
for (LocalResourcesTracker t : privateRsrc.values()) {
retain.addResources(t);
- LOG.debug("Resource cleanup " + t.getUser() + ":" + retain);
+ if (LOG.isDebugEnabled()) {
+ LOG.debug("Resource cleanup " + t.getUser() + ":" + retain);
+ }
}
//TODO Check if appRsrcs should also be added to the retention set.
}