This is an automated email from the ASF dual-hosted git repository. epayne pushed a commit to branch branch-3.3 in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/branch-3.3 by this push: new 4518ece YARN-4589: Diagnostics for localization timeouts is lacking. Contributed by Chang Li (lichangleo) and Jim Brennan (Jim_Brennan) 4518ece is described below commit 4518ece4c94a1aeda377918ef829caaec0686ac3 Author: Eric Payne <epa...@apache.org> AuthorDate: Wed Jan 13 17:01:28 2021 +0000 YARN-4589: Diagnostics for localization timeouts is lacking. Contributed by Chang Li (lichangleo) and Jim Brennan (Jim_Brennan) (cherry picked from commit d8fadec944f155d909db0cb32825b0ea22929f91) --- .../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 a45f8a5..8ad9784 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; @@ -1240,6 +1241,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); return ContainerState.LOCALIZING; } else { container.sendScheduleEvent(); --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org