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 ep...@apache.org on 2021/01/13 19:59:10 UTC
[hadoop] branch branch-3.1 updated: YARN-4589: Diagnostics for
localization timeouts is lacking. Contributed by Chang Li (lichangleo) and
Jim Brennan (Jim_Brennan)
This is an automated email from the ASF dual-hosted git repository.
epayne pushed a commit to branch branch-3.1
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/branch-3.1 by this push:
new a4dea9d YARN-4589: Diagnostics for localization timeouts is lacking. Contributed by Chang Li (lichangleo) and Jim Brennan (Jim_Brennan)
a4dea9d is described below
commit a4dea9de142ec31fba6a904fd3bd69689df4e29c
Author: Eric Payne <ep...@apache.org>
AuthorDate: Wed Jan 13 19:44:26 2021 +0000
YARN-4589: Diagnostics for localization timeouts is lacking. Contributed by Chang Li (lichangleo) and Jim Brennan (Jim_Brennan)
(cherry picked from commit a093bd859da0d1f2834f873d4dbe2bbd2f00f2d2)
---
.../nodemanager/containermanager/container/ContainerImpl.java | 10 ++++++++++
1 file changed, 10 insertions(+)
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/container/ContainerImpl.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/container/ContainerImpl.java
index e1546d4..5241499 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/container/ContainerImpl.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/container/ContainerImpl.java
@@ -23,6 +23,7 @@ import java.io.IOException;
import java.net.URISyntaxException;
import java.nio.ByteBuffer;
import java.text.SimpleDateFormat;
+import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collection;
import java.util.Date;
@@ -1219,6 +1220,15 @@ public class ContainerImpl implements Container {
container.resourceSet.addResources(ctxt.getLocalResources());
container.dispatcher.getEventHandler().handle(
new ContainerLocalizationRequestEvent(container, req));
+ // Get list of resources for logging
+ List<String> resourcePaths = new ArrayList<>();
+ for (Collection<LocalResourceRequest> rsrcReqList : req.values()) {
+ for (LocalResourceRequest rsrc : rsrcReqList) {
+ resourcePaths.add(rsrc.getPath().toString());
+ }
+ }
+ LOG.info("Container " + container.getContainerId()
+ + " is localizing: " + resourcePaths);
} catch (URISyntaxException e) {
// malformed resource; abort container launch
LOG.warn("Failed to parse resource-request", e);
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org