hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gunt...@apache.org
Subject svn commit: r1531166 - /hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java
Date Fri, 11 Oct 2013 01:45:11 GMT
Author: gunther
Date: Fri Oct 11 01:45:11 2013
New Revision: 1531166

URL: http://svn.apache.org/r1531166
Log:
HIVE-5516: Update hive to use updated tez APIs (Vikram Dixit)

Modified:
    hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java

Modified: hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java
URL: http://svn.apache.org/viewvc/hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java?rev=1531166&r1=1531165&r2=1531166&view=diff
==============================================================================
--- hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java (original)
+++ hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java Fri Oct
11 01:45:11 2013
@@ -68,6 +68,7 @@ import org.apache.tez.dag.api.InputDescr
 import org.apache.tez.dag.api.OutputDescriptor;
 import org.apache.tez.dag.api.ProcessorDescriptor;
 import org.apache.tez.dag.api.Vertex;
+import org.apache.tez.mapreduce.common.MRInputSplitDistributor;
 import org.apache.tez.mapreduce.hadoop.InputSplitInfo;
 import org.apache.tez.mapreduce.hadoop.MRHelpers;
 import org.apache.tez.mapreduce.hadoop.MRJobConfig;
@@ -233,9 +234,10 @@ public class DagUtils {
       assert mapWork.getAliasToWork().keySet().size() == 1;
 
       String alias = mapWork.getAliasToWork().keySet().iterator().next();
+      byte[] mrInput = MRHelpers.createMRInputPayload(serializedConf, null);
       map.addInput(alias,
           new InputDescriptor(MRInput.class.getName()).
-               setUserPayload(serializedConf));
+               setUserPayload(mrInput), null);
 
       map.setTaskLocationsHint(inputSplitInfo.getTaskLocationHints());
 



Mime
View raw message