svn commit: r1470085 - /incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/launcher/ContainerLauncherImpl.java

[sseth]

Author: sseth
Date: Fri Apr 19 23:15:03 2013
New Revision: 1470085

URL: http://svn.apache.org/r1470085
Log:
TEZ-48. Fix ContainerLauncherImpl to work post YARN-441.

Modified:
    
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/launcher/ContainerLauncherImpl.java

Modified: 
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/launcher/ContainerLauncherImpl.java
URL: 
http://svn.apache.org/viewvc/incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/launcher/ContainerLauncherImpl.java?rev=1470085&r1=1470084&r2=1470085&view=diff
==============================================================================
--- 
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/launcher/ContainerLauncherImpl.java
 (original)
+++ 
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/launcher/ContainerLauncherImpl.java
 Fri Apr 19 23:15:03 2013
@@ -160,8 +160,8 @@ public class ContainerLauncherImpl exten
         startRequest.setContainerLaunchContext(containerLaunchContext);
         StartContainerResponse response = proxy.startContainer(startRequest);
 
-        ByteBuffer portInfo = response
-          .getServiceResponse(ShuffleHandler.MAPREDUCE_SHUFFLE_SERVICEID);
+        ByteBuffer portInfo = response.getAllServiceResponse().get(
+            ShuffleHandler.MAPREDUCE_SHUFFLE_SERVICEID);
         int port = -1;
         if(portInfo != null) {
           port = ShuffleHandler.deserializeMetaData(portInfo);