TEZ-173. Fix ContainerLauncher to use containerToken in the startContainer call [YARN-684]. (sseth)
Project: http://git-wip-us.apache.org/repos/asf/incubator-tez/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-tez/commit/a6791898 Tree: http://git-wip-us.apache.org/repos/asf/incubator-tez/tree/a6791898 Diff: http://git-wip-us.apache.org/repos/asf/incubator-tez/diff/a6791898 Branch: refs/heads/master Commit: a6791898ee72ac1e23aca93b458000e2207bfb35 Parents: 5d0b8ad Author: Siddharth Seth <[email protected]> Authored: Thu May 30 22:24:14 2013 -0700 Committer: Siddharth Seth <[email protected]> Committed: Thu May 30 22:24:14 2013 -0700 ---------------------------------------------------------------------- .../dag/app/launcher/ContainerLauncherImpl.java | 2 +- 1 files changed, 1 insertions(+), 1 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/a6791898/tez-dag/src/main/java/org/apache/tez/dag/app/launcher/ContainerLauncherImpl.java ---------------------------------------------------------------------- diff --git a/tez-dag/src/main/java/org/apache/tez/dag/app/launcher/ContainerLauncherImpl.java b/tez-dag/src/main/java/org/apache/tez/dag/app/launcher/ContainerLauncherImpl.java index f1a16b8..5b23c75 100644 --- a/tez-dag/src/main/java/org/apache/tez/dag/app/launcher/ContainerLauncherImpl.java +++ b/tez-dag/src/main/java/org/apache/tez/dag/app/launcher/ContainerLauncherImpl.java @@ -160,7 +160,7 @@ public class ContainerLauncherImpl extends AbstractService implements // Now launch the actual container StartContainerRequest startRequest = Records .newRecord(StartContainerRequest.class); - startRequest.setContainer(event.getContainer()); + startRequest.setContainerToken(event.getContainerToken()); startRequest.setContainerLaunchContext(containerLaunchContext); StartContainerResponse response = proxy.startContainer(startRequest);
