tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ss...@apache.org
Subject svn commit: r1470085 - /incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/launcher/ContainerLauncherImpl.java
Date Fri, 19 Apr 2013 23:15:03 GMT
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);



Mime
View raw message