Skip to content

Commit be1f287

Browse files
committed
check permission for LeveldbRMStateStore
1 parent f187e9b commit be1f287

File tree

1 file changed

+5
-1
lines changed
  • hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/recovery

1 file changed

+5
-1
lines changed

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/LeveldbRMStateStore.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -153,7 +153,11 @@ private Path getStorageDir() throws IOException {
153153
private Path createStorageDir() throws IOException {
154154
Path root = getStorageDir();
155155
FileSystem fs = FileSystem.getLocal(getConfig());
156-
fs.mkdirs(root, new FsPermission((short)0700));
156+
FsPermission perm = new FsPermission((short)0700);
157+
fs.mkdirs(root, perm);
158+
if (!perms.equals(perms.applyUMask(fs.getUMask()))) {
159+
fs.setPermission(root, perm);
160+
}
157161
return root;
158162
}
159163

0 commit comments

Comments
 (0)