YARN-6463. Correct spelling mistake in FileSystemRMStateStore. Contributed by Yeliang Cang.
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/7d33e515 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/7d33e515 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/7d33e515 Branch: refs/heads/HDFS-10467 Commit: 7d33e5154e6e2ea60c6188131e10f6421cb428e5 Parents: 28dde86 Author: Naganarasimha <[email protected]> Authored: Tue Apr 11 22:42:08 2017 +0530 Committer: Inigo <[email protected]> Committed: Mon Apr 17 11:17:01 2017 -0700 ---------------------------------------------------------------------- .../resourcemanager/recovery/FileSystemRMStateStore.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/7d33e515/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/FileSystemRMStateStore.java ---------------------------------------------------------------------- diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/FileSystemRMStateStore.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/FileSystemRMStateStore.java index 929e2da..9591945 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/FileSystemRMStateStore.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/FileSystemRMStateStore.java @@ -785,7 +785,7 @@ public class FileSystemRMStateStore extends RMStateStore { * atomic for underlying file system. */ protected void writeFile(Path outputPath, byte[] data, boolean - makeUnradableByAdmin) throws Exception { + makeUnreadableByAdmin) throws Exception { Path tempPath = new Path(outputPath.getParent(), outputPath.getName() + ".tmp"); FSDataOutputStream fsOut = null; @@ -793,7 +793,7 @@ public class FileSystemRMStateStore extends RMStateStore { // final status. try { fsOut = fs.create(tempPath, true); - if (makeUnradableByAdmin) { + if (makeUnreadableByAdmin) { setUnreadableBySuperuserXattrib(tempPath); } fsOut.write(data); @@ -811,10 +811,10 @@ public class FileSystemRMStateStore extends RMStateStore { * atomic for underlying file system. */ protected void updateFile(Path outputPath, byte[] data, boolean - makeUnradableByAdmin) throws Exception { + makeUnreadableByAdmin) throws Exception { Path newPath = new Path(outputPath.getParent(), outputPath.getName() + ".new"); // use writeFileWithRetries to make sure .new file is created atomically - writeFileWithRetries(newPath, data, makeUnradableByAdmin); + writeFileWithRetries(newPath, data, makeUnreadableByAdmin); replaceFile(newPath, outputPath); } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
