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 zj...@apache.org on 2015/04/06 21:22:40 UTC
[10/50] [abbrv] hadoop git commit: YARN-3428. Debug log resources to
be localized for a container. (kasha)
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/b62eb19e
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/b62eb19e
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/b62eb19e
Branch: refs/heads/YARN-2928
Commit: b62eb19ef02a23a766e4d8fa5172d57a36aec849
Parents: 0834fe3
Author: Karthik Kambatla <ka...@apache.org>
Authored: Tue Mar 31 17:34:40 2015 -0700
Committer: Zhijie Shen <zj...@apache.org>
Committed: Mon Apr 6 12:08:10 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/b62eb19e/hadoop-yarn-project/CHANGES.txt
----------------------------------------------------------------------
diff --git a/hadoop-yarn-project/CHANGES.txt b/hadoop-yarn-project/CHANGES.txt
index 3cf9847..dab8116 100644
--- a/hadoop-yarn-project/CHANGES.txt
+++ b/hadoop-yarn-project/CHANGES.txt
@@ -145,6 +145,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/b62eb19e/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.
}