svn commit: r1529345 - /hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/MapOperator.java

[gu...@apache.org]

Author: gunther
Date: Fri Oct  4 23:15:24 2013
New Revision: 1529345

URL: http://svn.apache.org/r1529345
Log:
HIVE-5451: Use IOContext instead of HADOOPMAPFILENAME in MapOperator setup for Tez (Gunther Hagleitner)

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

Modified: hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/MapOperator.java
URL: http://svn.apache.org/viewvc/hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/MapOperator.java?rev=1529345&r1=1529344&r2=1529345&view=diff
==============================================================================
--- hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/MapOperator.java (original)
+++ hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/MapOperator.java Fri Oct  4 23:15:24 2013
@@ -33,6 +33,7 @@ import org.apache.hadoop.conf.Configurat
 import org.apache.hadoop.fs.Path;
 import org.apache.hadoop.hive.conf.HiveConf;
 import org.apache.hadoop.hive.metastore.api.hive_metastoreConstants;
+import org.apache.hadoop.hive.ql.io.IOContext;
 import org.apache.hadoop.hive.ql.exec.mr.ExecMapperContext;
 import org.apache.hadoop.hive.ql.metadata.HiveException;
 import org.apache.hadoop.hive.ql.metadata.VirtualColumn;
@@ -321,8 +322,7 @@ public class MapOperator extends Operato
 
   public void setChildren(Configuration hconf) throws HiveException {
 
-    Path fpath = new Path(HiveConf.getVar(hconf,
-        HiveConf.ConfVars.HADOOPMAPFILENAME));
+    Path fpath = new Path(IOContext.get().getInputFile());
 
     boolean schemeless = fpath.toUri().getScheme() == null;