You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@hive.apache.org by go...@apache.org on 2014/10/13 23:36:40 UTC

svn commit: r1631565 - /hive/branches/branch-0.14/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordSource.java

Author: gopalv
Date: Mon Oct 13 21:36:40 2014
New Revision: 1631565

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

Modified:
    hive/branches/branch-0.14/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordSource.java

Modified: hive/branches/branch-0.14/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordSource.java
URL: http://svn.apache.org/viewvc/hive/branches/branch-0.14/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordSource.java?rev=1631565&r1=1631564&r2=1631565&view=diff
==============================================================================
--- hive/branches/branch-0.14/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordSource.java (original)
+++ hive/branches/branch-0.14/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordSource.java Mon Oct 13 21:36:40 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;
   }