YARN-8326. Removed exit code file check for launched container. Contributed by Shane Kumpf
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/8a32bc39 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/8a32bc39 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/8a32bc39 Branch: refs/heads/HDDS-4 Commit: 8a32bc39eb210fca8052c472601e24c2446b4cc2 Parents: 1cdce86 Author: Eric Yang <ey...@apache.org> Authored: Fri Jun 22 19:12:48 2018 -0400 Committer: Eric Yang <ey...@apache.org> Committed: Fri Jun 22 19:12:48 2018 -0400 ---------------------------------------------------------------------- .../launcher/ContainerLaunch.java | 19 ------------------- 1 file changed, 19 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/8a32bc39/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/launcher/ContainerLaunch.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/launcher/ContainerLaunch.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/launcher/ContainerLaunch.java index bb842af..04295e1 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/launcher/ContainerLaunch.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/launcher/ContainerLaunch.java @@ -808,25 +808,6 @@ public class ContainerLaunch implements Callable<Integer> { } } - final int sleepMsec = 100; - int msecLeft = 2000; - if (pidFilePath != null) { - File file = new File(getExitCodeFile(pidFilePath.toString())); - while (!file.exists() && msecLeft >= 0) { - try { - Thread.sleep(sleepMsec); - } catch (InterruptedException e) { - } - msecLeft -= sleepMsec; - } - if (msecLeft < 0) { - if (LOG.isDebugEnabled()) { - LOG.debug("Timeout while waiting for the exit code file: " - + file.getAbsolutePath()); - } - } - } - // Reap the container boolean result = exec.reapContainer( new ContainerReapContext.Builder() --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org