diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java index 776b3b2..330c4d7 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java @@ -263,7 +263,9 @@ public static BaseWork getBaseWork(Configuration conf, String name) { gWork = gWorkMap.get(path); if (gWork == null) { Path localPath; - if (ShimLoader.getHadoopShims().isLocalMode(conf)) { + if (conf.getBoolean("mapreduce.task.uberized", false) && name.equals(REDUCE_PLAN_NAME)) { + localPath = new Path(name); + } else if (ShimLoader.getHadoopShims().isLocalMode(conf)) { localPath = path; } else { localPath = new Path(name);