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 17:14:20 UTC
[hadoop] branch trunk 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 trunk
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/trunk by this push:
new d8fadec YARN-4589: Diagnostics for localization timeouts is lacking. Contributed by Chang Li (lichangleo) and Jim Brennan (Jim_Brennan)
d8fadec is described below
commit d8fadec944f155d909db0cb32825b0ea22929f91
Author: Eric Payne <ep...@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)
---
.../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-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org