svn commit: r1631561 - /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordSource.java

[gopalv]

Author: gopalv
Date: Mon Oct 13 21:32:20 2014
New Revision: 1631561

URL: http://svn.apache.org/r1631561
Log:
HIVE-8292: MapRecordSource should obtain its ExecContext from a MapOperator 
(Gopal V, reviewed by Vikram Dixit)

Modified:
    
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordSource.java

Modified: 
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordSource.java
URL: 
http://svn.apache.org/viewvc/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordSource.java?rev=1631561&r1=1631560&r2=1631561&view=diff
==============================================================================
--- 
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordSource.java 
(original)
+++ 
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordSource.java 
Mon Oct 13 21:32:20 2014
@@ -45,7 +45,7 @@ public class MapRecordSource implements 
   private final boolean grouped = false;
 
   void init(JobConf jconf, MapOperator mapOp, KeyValueReader reader) throws 
IOException {
-    execContext = new ExecMapperContext(jconf);
+    execContext = mapOp.getExecContext();
     this.mapOp = mapOp;
     this.reader = reader;
   }