diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/util/FSDownload.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/util/FSDownload.java index f34c16c..b6cda12 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/util/FSDownload.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/util/FSDownload.java @@ -347,6 +347,9 @@ public Path call() throws Exception { final Path sCopy; try { sCopy = resource.getResource().toPath(); + if (LOG.isDebugEnabled()) { + LOG.debug("Starting to download " + sCopy); + } } catch (URISyntaxException e) { throw new IOException("Invalid resource", e); } @@ -364,6 +367,11 @@ public Path run() throws Exception { unpack(new File(dTmp.toUri()), new File(dFinal.toUri())); changePermissions(dFinal.getFileSystem(conf), dFinal); files.rename(dst_work, destDirPath, Rename.OVERWRITE); + + if (LOG.isDebugEnabled()) { + LOG.debug("File has been downloaded to: " + + new Path(destDirPath, sCopy.getName())); + } } catch (Exception e) { try { files.delete(destDirPath, true); @@ -409,8 +417,11 @@ private void changePermissions(FileSystem fs, final Path path) // APPLICATION: perm = isDir ? PRIVATE_DIR_PERMS : PRIVATE_FILE_PERMS; } - LOG.debug("Changing permissions for path " + path - + " to perm " + perm); + + if (LOG.isDebugEnabled()) { + LOG.debug("Changing permissions for path " + path + " to perm " + perm); + } + final FsPermission fPerm = perm; if (null == userUgi) { files.setPermission(path, perm);