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/HDFS-12943
Commit: 8a32bc39eb210fca8052c472601e24c2446b4cc2
Parents: 1cdce86
Author: Eric Yang <[email protected]>
Authored: Fri Jun 22 19:12:48 2018 -0400
Committer: Eric Yang <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
