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;
}