Index: ql/src/java/org/apache/hadoop/hive/ql/metadata/Hive.java =================================================================== --- ql/src/java/org/apache/hadoop/hive/ql/metadata/Hive.java (revision 1049722) +++ ql/src/java/org/apache/hadoop/hive/ql/metadata/Hive.java (working copy) @@ -1545,13 +1545,9 @@ try { fs.mkdirs(tmppath); for (FileStatus src : srcs) { - FileStatus[] items = fs.listStatus(src.getPath()); - for (int j = 0; j < items.length; j++) { - if (!fs.rename(items[j].getPath(), new Path(tmppath, items[j] - .getPath().getName()))) { - throw new HiveException("Error moving: " + items[j].getPath() + if (!fs.rename(src.getPath(), tmppath)) { + throw new HiveException("Error moving: " + src.getPath() + " into: " + tmppath); - } } }