diff --git ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/CompactorMR.java ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/CompactorMR.java index c3e3982..de0e70e 100644 --- ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/CompactorMR.java +++ ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/CompactorMR.java @@ -843,11 +843,7 @@ public void commitJob(JobContext context) throws IOException { LOG.debug("Moving contents of " + tmpLocation.toString() + " to " + finalLocation.toString()); - FileStatus[] contents = fs.listStatus(tmpLocation); - for (int i = 0; i < contents.length; i++) { - Path newPath = new Path(finalLocation, contents[i].getPath().getName()); - fs.rename(contents[i].getPath(), newPath); - } + fs.rename(tmpLocation, finalLocation); fs.delete(tmpLocation, true); }