diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java index 449bef8..0bdc465 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java @@ -263,7 +263,8 @@ public static void clearWork(Configuration conf) { } try { - FileSystem fs = mapPath.getFileSystem(conf); + Path p = mapPath == null ? reducePath : mapPath; + FileSystem fs = p.getFileSystem(conf); if (fs.exists(mapPath)) { fs.delete(mapPath, true); }