diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/MapOperator.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/MapOperator.java index 7821346..8122afa 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/MapOperator.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/MapOperator.java @@ -347,6 +347,8 @@ public void setChildren(Configuration hconf) throws HiveException { Path fpath = new Path(HiveConf.getVar(hconf, HiveConf.ConfVars.HADOOPMAPFILENAME)); + boolean schemeless = fpath.toUri().getScheme() == null; + List> children = new ArrayList>(); @@ -358,6 +360,10 @@ public void setChildren(Configuration hconf) throws HiveException { List aliases = entry.getValue(); Path onepath = new Path(onefile); + if (schemeless) { + onepath = new Path(onepath.toUri().getPath()); + } + PartitionDesc partDesc = conf.getPathToPartitionInfo().get(onefile); for (String onealias : aliases) {