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

YARN-6463. Correct spelling mistake in FileSystemRMStateStore. Contributed by Yeliang Cang.

This commit is contained in:
Naganarasimha 2017-04-11 22:42:08 +05:30
parent f050afb578
commit 7d873c465b
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/FileSystemRMStateStore.java
View File

@ -785,7 +785,7 @@ public class FileSystemRMStateStore extends RMStateStore {
* atomic for underlying file system. * atomic for underlying file system.
*/ */
protected void writeFile(Path outputPath, byte[] data, boolean protected void writeFile(Path outputPath, byte[] data, boolean
makeUnradableByAdmin) throws Exception { makeUnreadableByAdmin) throws Exception {
Path tempPath = Path tempPath =
new Path(outputPath.getParent(), outputPath.getName() + ".tmp"); new Path(outputPath.getParent(), outputPath.getName() + ".tmp");
FSDataOutputStream fsOut = null; FSDataOutputStream fsOut = null;
@ -793,7 +793,7 @@ public class FileSystemRMStateStore extends RMStateStore {
// final status. // final status.
try { try {
fsOut = fs.create(tempPath, true); fsOut = fs.create(tempPath, true);
if (makeUnradableByAdmin) { if (makeUnreadableByAdmin) {
setUnreadableBySuperuserXattrib(tempPath); setUnreadableBySuperuserXattrib(tempPath);
} }
fsOut.write(data); fsOut.write(data);
@ -811,10 +811,10 @@ public class FileSystemRMStateStore extends RMStateStore {
* atomic for underlying file system. * atomic for underlying file system.
*/ */
protected void updateFile(Path outputPath, byte[] data, boolean protected void updateFile(Path outputPath, byte[] data, boolean
makeUnradableByAdmin) throws Exception { makeUnreadableByAdmin) throws Exception {
Path newPath = new Path(outputPath.getParent(), outputPath.getName() + ".new"); Path newPath = new Path(outputPath.getParent(), outputPath.getName() + ".new");
// use writeFileWithRetries to make sure .new file is created atomically // use writeFileWithRetries to make sure .new file is created atomically
writeFileWithRetries(newPath, data, makeUnradableByAdmin); writeFileWithRetries(newPath, data, makeUnreadableByAdmin);
replaceFile(newPath, outputPath); replaceFile(newPath, outputPath);
} }