Addendum fix for HDFS-8323 (adding back a mistakenly deleted line).
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/3a240015 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/3a240015 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/3a240015 Branch: refs/heads/HDFS-7285-REBASE Commit: 3a2400159fa2b23a1bbae1c8817290e79163dbec Parents: 4bed451 Author: Zhe Zhang <[email protected]> Authored: Wed Jul 8 22:52:09 2015 -0700 Committer: Vinayakumar B <[email protected]> Committed: Thu Aug 13 17:17:24 2015 +0530 ---------------------------------------------------------------------- .../java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/3a240015/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java index dc892e0..2634937 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java @@ -5353,6 +5353,8 @@ public class FSNamesystem implements Namesystem, FSNamesystemMBean, locatedBlock = BlockManager.newLocatedBlock( block, file.getLastBlock(), null, -1); + blockManager.setBlockToken(locatedBlock, + BlockTokenIdentifier.AccessMode.WRITE); } finally { writeUnlock(); }
