diff --git a/ql/src/java/org/apache/hadoop/hive/ql/metadata/Hive.java b/ql/src/java/org/apache/hadoop/hive/ql/metadata/Hive.java index 5b908e8453..019c14ddf3 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/metadata/Hive.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/metadata/Hive.java @@ -1972,7 +1972,8 @@ public Void call() throws Exception { try { // move file would require session details (needCopy() invokes SessionState.get) SessionState.setCurrentSessionState(parentSession); - LOG.info("New loading path = " + partPath + " with partSpec " + fullPartSpec); + LOG.info("New loading path = " + partPath + + " with partSpec " + fullPartSpec); // load the partition Partition newPartition = loadPartition(partPath, tbl, fullPartSpec, @@ -2987,6 +2988,7 @@ private static void copyFiles(final HiveConf conf, final FileSystem destFs, futures.add(pool.submit(new Callable>() { @Override public ObjectPair call() throws Exception { + LOG.info("copying file"); SessionState.setCurrentSessionState(parentSession); Path destPath = mvFile(conf, srcFs, srcP, destFs, destf, isSrcLocal, isRenameAllowed); @@ -3244,6 +3246,7 @@ public static boolean moveFile(final HiveConf conf, Path srcf, final Path destf, public Void call() throws Exception { SessionState.setCurrentSessionState(parentSession); final String group = srcStatus.getGroup(); + LOG.info("moving file"); if(!destFs.rename(srcStatus.getPath(), destFile)) { throw new IOException("rename for src path: " + srcStatus.getPath() + " to dest path:" + destFile + " returned false"); @@ -3587,6 +3590,7 @@ public static boolean trashFiles(final FileSystem fs, final FileStatus[] statuse @Override public Boolean call() throws Exception { SessionState.setCurrentSessionState(parentSession); + LOG.info("deleting file"); return FileUtils.moveToTrash(fs, status.getPath(), conf, purge); } }));