Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

YARN-7879. NM user is unable to access the application filecache due to permissions. Contributed by Jason Lowe.

This commit is contained in:
Miklos Szegedi 2018-02-02 11:38:21 -08:00
parent 0ef639235b
commit c7101fe21b
2 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/util/FSDownload.java
View File

@ -401,7 +401,7 @@ public class FSDownload implements Callable<Path> {
} }
final Path destinationTmp = new Path(destDirPath + "_tmp"); final Path destinationTmp = new Path(destDirPath + "_tmp");
createDir(destinationTmp, PRIVATE_DIR_PERMS); createDir(destinationTmp, cachePerms);
Path dFinal = Path dFinal =
files.makeQualified(new Path(destinationTmp, sCopy.getName())); files.makeQualified(new Path(destinationTmp, sCopy.getName()));
try { try {
@ -416,10 +416,7 @@ public class FSDownload implements Callable<Path> {
} }
}); });
} }
Path destinationTmpfilesQualified = files.makeQualified(destinationTmp); changePermissions(dFinal.getFileSystem(conf), dFinal);
changePermissions(
destinationTmpfilesQualified.getFileSystem(conf),
destinationTmpfilesQualified);
files.rename(destinationTmp, destDirPath, Rename.OVERWRITE); files.rename(destinationTmp, destDirPath, Rename.OVERWRITE);
if (LOG.isDebugEnabled()) { if (LOG.isDebugEnabled()) {

2
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/test/java/org/apache/hadoop/yarn/util/TestFSDownload.java
View File

@ -451,7 +451,7 @@ public class TestFSDownload {
FileStatus status = files.getFileStatus(localized.getParent()); FileStatus status = files.getFileStatus(localized.getParent());
FsPermission perm = status.getPermission(); FsPermission perm = status.getPermission();
assertEquals("Cache directory permissions are incorrect", assertEquals("Cache directory permissions are incorrect",
new FsPermission((short)0700), perm); new FsPermission((short)0755), perm);
status = files.getFileStatus(localized); status = files.getFileStatus(localized);
perm = status.getPermission(); perm = status.getPermission();