Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 28252200CBC for ; Tue, 20 Jun 2017 19:12:21 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 270A0160BE1; Tue, 20 Jun 2017 17:12:21 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id EB239160BCC for ; Tue, 20 Jun 2017 19:12:19 +0200 (CEST) Received: (qmail 39276 invoked by uid 500); 20 Jun 2017 17:12:18 -0000 Mailing-List: contact common-commits-help@hadoop.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Delivered-To: mailing list common-commits@hadoop.apache.org Received: (qmail 39263 invoked by uid 99); 20 Jun 2017 17:12:18 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 20 Jun 2017 17:12:18 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 062C0DFAF5; Tue, 20 Jun 2017 17:12:18 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: kihwal@apache.org To: common-commits@hadoop.apache.org Message-Id: <4e3df2d74c9541cba3cbdfe8cec95ae2@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: hadoop git commit: HDFS-9754. Avoid unnecessary getBlockCollection calls in BlockManager. Contributed by Jing Zhao. Date: Tue, 20 Jun 2017 17:12:18 +0000 (UTC) archived-at: Tue, 20 Jun 2017 17:12:21 -0000 Repository: hadoop Updated Branches: refs/heads/branch-2.8 1f9255672 -> e87bf1712 HDFS-9754. Avoid unnecessary getBlockCollection calls in BlockManager. Contributed by Jing Zhao. (cherry picked from commit 972782d9568e0849484c027f27c1638ba50ec56e) (cherry picked from commit f8c9c0ff0e2d977fc0f69bde4cdbb03371c0bac4) Conflicts: hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockManager.java hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/Namesystem.java hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/namenode/TestNameNodeMetadataConsistency.java Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/e87bf171 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/e87bf171 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/e87bf171 Branch: refs/heads/branch-2.8 Commit: e87bf17129681bce490f59164b51792faf06ccb8 Parents: 1f92556 Author: Kihwal Lee Authored: Tue Jun 20 12:10:43 2017 -0500 Committer: Kihwal Lee Committed: Tue Jun 20 12:10:43 2017 -0500 ---------------------------------------------------------------------- .../hdfs/server/blockmanagement/BlockInfo.java | 10 ++++ .../server/blockmanagement/BlockManager.java | 50 ++++++++------------ .../hdfs/server/blockmanagement/BlocksMap.java | 2 +- .../hdfs/server/namenode/FSDirTruncateOp.java | 8 ++-- .../hdfs/server/namenode/FSNamesystem.java | 6 +-- .../hadoop/hdfs/server/namenode/INode.java | 6 +-- .../hadoop/hdfs/server/namenode/INodeFile.java | 38 +++++++-------- .../hadoop/hdfs/server/namenode/Namesystem.java | 6 +-- .../snapshot/FileWithSnapshotFeature.java | 2 +- .../TestNameNodeMetadataConsistency.java | 4 +- 10 files changed, 62 insertions(+), 70 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/e87bf171/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockInfo.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockInfo.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockInfo.java index d62abee..7f945c0 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockInfo.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockInfo.java @@ -114,6 +114,10 @@ public abstract class BlockInfo extends Block this.bcId = id; } + public void delete() { + setBlockCollectionId(INVALID_INODE_ID); + } + public boolean isDeleted() { return bcId == INVALID_INODE_ID; } @@ -353,6 +357,12 @@ public abstract class BlockInfo extends Block return getBlockUCState().equals(BlockUCState.COMPLETE); } + public final boolean isCompleteOrCommitted() { + final BlockUCState state = getBlockUCState(); + return state.equals(BlockUCState.COMPLETE) || + state.equals(BlockUCState.COMMITTED); + } + /** * Add/Update the under construction feature. */ http://git-wip-us.apache.org/repos/asf/hadoop/blob/e87bf171/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockManager.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockManager.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockManager.java index ed00cd1..94bb736 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockManager.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockManager.java @@ -737,19 +737,19 @@ public class BlockManager implements BlockStatsMXBean { if(lastBlock.isComplete()) return false; // already completed (e.g. by syncBlock) - final boolean b = commitBlock(lastBlock, commitBlock); + final boolean committed = commitBlock(lastBlock, commitBlock); // Count replicas on decommissioning nodes, as these will not be // decommissioned unless recovery/completing last block has finished NumberReplicas numReplicas = countNodes(lastBlock); if (numReplicas.liveReplicas() + numReplicas.decommissioning() >= minReplication) { - if (b) { - addExpectedReplicasToPending(lastBlock, bc); + if (committed) { + addExpectedReplicasToPending(lastBlock); } completeBlock(lastBlock, iip, false); } - return b; + return committed; } /** @@ -757,24 +757,20 @@ public class BlockManager implements BlockStatsMXBean { * pendingReplications in order to keep ReplicationMonitor from scheduling * the block. */ - public void addExpectedReplicasToPending(BlockInfo blk, BlockCollection bc) { - addExpectedReplicasToPending(blk); - } - - private void addExpectedReplicasToPending(BlockInfo lastBlock) { + public void addExpectedReplicasToPending(BlockInfo blk) { DatanodeStorageInfo[] expectedStorages = - lastBlock.getUnderConstructionFeature().getExpectedStorageLocations(); - if (expectedStorages.length - lastBlock.numNodes() > 0) { + blk.getUnderConstructionFeature().getExpectedStorageLocations(); + if (expectedStorages.length - blk.numNodes() > 0) { ArrayList pendingNodes = new ArrayList(); for (DatanodeStorageInfo storage : expectedStorages) { DatanodeDescriptor dnd = storage.getDatanodeDescriptor(); - if (lastBlock.findStorageInfo(dnd) == null) { + if (blk.findStorageInfo(dnd) == null) { pendingNodes.add(dnd); } + pendingReplications.increment(blk, + pendingNodes.toArray(new DatanodeDescriptor[pendingNodes.size()])); } - pendingReplications.increment(lastBlock, - pendingNodes.toArray(new DatanodeDescriptor[pendingNodes.size()])); } } @@ -1586,11 +1582,8 @@ public class BlockManager implements BlockStatsMXBean { } private ReplicationWork scheduleReplication(BlockInfo block, int priority) { - // block should belong to a file - BlockCollection bc = getBlockCollection(block); - // abandoned block or block reopened for append - if (bc == null - || (bc.isUnderConstruction() && block.equals(bc.getLastBlock()))) { + // skip abandoned block or block reopened for append + if (block.isDeleted() || !block.isCompleteOrCommitted()) { // remove from neededReplications neededReplications.remove(block, priority); return null; @@ -1629,6 +1622,7 @@ public class BlockManager implements BlockStatsMXBean { } else { additionalReplRequired = 1; // Needed on a new rack } + final BlockCollection bc = getBlockCollection(block); return new ReplicationWork(block, bc, srcNode, containingNodes, liveReplicaNodes, additionalReplRequired, priority); } @@ -1637,11 +1631,8 @@ public class BlockManager implements BlockStatsMXBean { BlockInfo block = rw.getBlock(); int priority = rw.getPriority(); // Recheck since global lock was released - // block should belong to a file - BlockCollection bc = getBlockCollection(block); - // abandoned block or block reopened for append - if (bc == null - || (bc.isUnderConstruction() && block.equals(bc.getLastBlock()))) { + // skip abandoned block or block reopened for append + if (block.isDeleted() || !block.isCompleteOrCommitted()) { neededReplications.remove(block, priority); rw.resetTargets(); return false; @@ -2685,8 +2676,6 @@ public class BlockManager implements BlockStatsMXBean { // it will happen in next block report otherwise. return block; } - BlockCollection bc = getBlockCollection(storedBlock); - assert bc != null : "Block must belong to a file"; // add block to the datanode AddBlockResult result = storageInfo.addBlock(storedBlock); @@ -2722,7 +2711,7 @@ public class BlockManager implements BlockStatsMXBean { if(storedBlock.getBlockUCState() == BlockUCState.COMMITTED && numLiveReplicas >= minReplication) { - addExpectedReplicasToPending(storedBlock, bc); + addExpectedReplicasToPending(storedBlock); completeBlock(storedBlock, null, false); } else if (storedBlock.isComplete() && result == AddBlockResult.ADDED) { // check whether safe replication is reached for the block @@ -2733,8 +2722,8 @@ public class BlockManager implements BlockStatsMXBean { namesystem.incrementSafeBlockCount(numCurrentReplica); } - // if file is under construction, then done for now - if (bc.isUnderConstruction()) { + // if block is still under construction, then done for now + if (!storedBlock.isCompleteOrCommitted()) { return storedBlock; } @@ -3148,8 +3137,7 @@ public class BlockManager implements BlockStatsMXBean { // necessary. In that case, put block on a possibly-will- // be-replicated list. // - BlockCollection bc = getBlockCollection(storedBlock); - if (bc != null) { + if (!storedBlock.isDeleted()) { namesystem.decrementSafeBlockCount(storedBlock); updateNeededReplications(storedBlock, -1, 0); } http://git-wip-us.apache.org/repos/asf/hadoop/blob/e87bf171/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlocksMap.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlocksMap.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlocksMap.java index 72a45c3..62bfd28 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlocksMap.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlocksMap.java @@ -114,7 +114,7 @@ class BlocksMap { if (blockInfo == null) return; - blockInfo.setBlockCollectionId(INodeId.INVALID_INODE_ID); + assert blockInfo.getBlockCollectionId() == INodeId.INVALID_INODE_ID; for(int idx = blockInfo.numNodes()-1; idx >= 0; idx--) { DatanodeDescriptor dn = blockInfo.getDatanode(idx); if (dn != null) { http://git-wip-us.apache.org/repos/asf/hadoop/blob/e87bf171/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSDirTruncateOp.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSDirTruncateOp.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSDirTruncateOp.java index 0d28b17..68a3362 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSDirTruncateOp.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSDirTruncateOp.java @@ -18,6 +18,7 @@ package org.apache.hadoop.hdfs.server.namenode; import java.io.IOException; +import java.util.Set; import org.apache.hadoop.HadoopIllegalArgumentException; import org.apache.hadoop.fs.FileStatus; @@ -178,6 +179,7 @@ final class FSDirTruncateOp { "Should be the same block."; if (oldBlock.getBlockId() != tBlk.getBlockId() && !file.isBlockInLatestSnapshot(oldBlock)) { + oldBlock.delete(); fsd.getBlockManager().removeBlockFromMap(oldBlock); } } @@ -288,9 +290,9 @@ final class FSDirTruncateOp { verifyQuotaForTruncate(fsn, iip, file, newLength, delta); - long remainingLength = - file.collectBlocksBeyondMax(newLength, collectedBlocks); - file.excludeSnapshotBlocks(latestSnapshot, collectedBlocks); + Set toRetain = file.getSnapshotBlocksToRetain(latestSnapshot); + long remainingLength = file.collectBlocksBeyondMax(newLength, + collectedBlocks, toRetain); file.setModificationTime(mtime); // return whether on a block boundary return (remainingLength - newLength) == 0; http://git-wip-us.apache.org/repos/asf/hadoop/blob/e87bf171/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 efd20c3..ec678b8 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 @@ -3308,7 +3308,7 @@ public class FSNamesystem implements Namesystem, FSNamesystemMBean, final BlockInfo b = blocks[i]; if (b != null && b.getBlockUCState() == BlockUCState.COMMITTED) { // b is COMMITTED but not yet COMPLETE, add it to pending replication. - blockManager.addExpectedReplicasToPending(b, pendingFile); + blockManager.addExpectedReplicasToPending(b); } } } @@ -5129,9 +5129,7 @@ public class FSNamesystem implements Namesystem, FSNamesystemMBean, return new PermissionStatus(fsOwner.getShortUserName(), supergroup, permission); } - @Override - public void checkSuperuserPrivilege() - throws AccessControlException { + void checkSuperuserPrivilege() throws AccessControlException { if (isPermissionEnabled) { FSPermissionChecker pc = getPermissionChecker(); pc.checkSuperuserPrivilege(); http://git-wip-us.apache.org/repos/asf/hadoop/blob/e87bf171/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/INode.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/INode.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/INode.java index 2804c7b..c6258a1 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/INode.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/INode.java @@ -1040,14 +1040,10 @@ public abstract class INode implements INodeAttributes, Diff.Element { */ public void addDeleteBlock(BlockInfo toDelete) { assert toDelete != null : "toDelete is null"; + toDelete.delete(); toDeleteList.add(toDelete); } - public void removeDeleteBlock(BlockInfo block) { - assert block != null : "block is null"; - toDeleteList.remove(block); - } - public void addUpdateReplicationFactor(BlockInfo block, short targetRepl) { toUpdateReplicationInfo.add( new UpdatedReplicationInfo(targetRepl, block)); http://git-wip-us.apache.org/repos/asf/hadoop/blob/e87bf171/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/INodeFile.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/INodeFile.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/INodeFile.java index 64d859d..116b517 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/INodeFile.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/INodeFile.java @@ -25,6 +25,7 @@ import java.io.FileNotFoundException; import java.io.IOException; import java.io.PrintWriter; import java.util.Arrays; +import java.util.Collections; import java.util.HashSet; import java.util.List; import java.util.Set; @@ -290,12 +291,13 @@ public class INodeFile extends INodeWithAdditionalFields return null; } - BlockInfo ucBlock = blocks[size_1]; + BlockInfo lastBlock = blocks[size_1]; //copy to a new list BlockInfo[] newlist = new BlockInfo[size_1]; System.arraycopy(blocks, 0, newlist, 0, size_1); setBlocks(newlist); - return ucBlock; + lastBlock.delete(); + return lastBlock; } /* End of Under-Construction Feature */ @@ -571,7 +573,6 @@ public class INodeFile extends INodeWithAdditionalFields if (blocks != null && reclaimContext.collectedBlocks != null) { for (BlockInfo blk : blocks) { reclaimContext.collectedBlocks.addDeleteBlock(blk); - blk.setBlockCollectionId(INodeId.INVALID_INODE_ID); } } clearBlocks(); @@ -801,7 +802,7 @@ public class INodeFile extends INodeWithAdditionalFields * @return sum of sizes of the remained blocks */ public long collectBlocksBeyondMax(final long max, - final BlocksMapUpdateInfo collectedBlocks) { + final BlocksMapUpdateInfo collectedBlocks, Set toRetain) { final BlockInfo[] oldBlocks = getBlocks(); if (oldBlocks == null) { return 0; @@ -823,7 +824,10 @@ public class INodeFile extends INodeWithAdditionalFields // collect the blocks beyond max if (collectedBlocks != null) { for(; n < oldBlocks.length; n++) { - collectedBlocks.addDeleteBlock(oldBlocks[n]); + final BlockInfo del = oldBlocks[n]; + if (toRetain == null || !toRetain.contains(del)) { + collectedBlocks.addDeleteBlock(del); + } } } return size; @@ -914,22 +918,18 @@ public class INodeFile extends INodeWithAdditionalFields } /** Exclude blocks collected for deletion that belong to a snapshot. */ - void excludeSnapshotBlocks(int snapshotId, - BlocksMapUpdateInfo collectedBlocks) { - if(collectedBlocks == null || collectedBlocks.getToDeleteList().isEmpty()) - return; + Set getSnapshotBlocksToRetain(int snapshotId) { FileWithSnapshotFeature sf = getFileWithSnapshotFeature(); - if(sf == null) - return; - BlockInfo[] snapshotBlocks = - getDiffs().findEarlierSnapshotBlocks(snapshotId); - if(snapshotBlocks == null) - return; - List toDelete = collectedBlocks.getToDeleteList(); - for(BlockInfo blk : snapshotBlocks) { - if(toDelete.contains(blk)) - collectedBlocks.removeDeleteBlock(blk); + if(sf == null) { + return null; + } + BlockInfo[] snapshotBlocks = getDiffs().findEarlierSnapshotBlocks(snapshotId); + if(snapshotBlocks == null) { + return null; } + Set toRetain = new HashSet<>(snapshotBlocks.length); + Collections.addAll(toRetain, snapshotBlocks); + return toRetain; } /** http://git-wip-us.apache.org/repos/asf/hadoop/blob/e87bf171/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/Namesystem.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/Namesystem.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/Namesystem.java index ae96be9..365028c 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/Namesystem.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/Namesystem.java @@ -24,7 +24,6 @@ import org.apache.hadoop.hdfs.server.namenode.NameNode.OperationCategory; import org.apache.hadoop.hdfs.server.namenode.ha.HAContext; import org.apache.hadoop.hdfs.util.RwLock; import org.apache.hadoop.ipc.StandbyException; -import org.apache.hadoop.security.AccessControlException; /** Namesystem operations. */ @InterfaceAudience.Private @@ -32,9 +31,6 @@ public interface Namesystem extends RwLock, SafeMode { /** Is this name system running? */ boolean isRunning(); - /** Check if the user has superuser privilege. */ - void checkSuperuserPrivilege() throws AccessControlException; - /** @return the block pool ID */ String getBlockPoolId(); @@ -54,4 +50,4 @@ public interface Namesystem extends RwLock, SafeMode { CacheManager getCacheManager(); HAContext getHAContext(); -} \ No newline at end of file +} http://git-wip-us.apache.org/repos/asf/hadoop/blob/e87bf171/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/snapshot/FileWithSnapshotFeature.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/snapshot/FileWithSnapshotFeature.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/snapshot/FileWithSnapshotFeature.java index 9a149f0..b52e8d6 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/snapshot/FileWithSnapshotFeature.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/snapshot/FileWithSnapshotFeature.java @@ -220,7 +220,7 @@ public class FileWithSnapshotFeature implements INode.Feature { FileDiff last = diffs.getLast(); BlockInfo[] snapshotBlocks = last == null ? null : last.getBlocks(); if(snapshotBlocks == null) - file.collectBlocksBeyondMax(max, reclaimContext.collectedBlocks()); + file.collectBlocksBeyondMax(max, reclaimContext.collectedBlocks(), null); else file.collectBlocksBeyondSnapshot(snapshotBlocks, reclaimContext.collectedBlocks()); http://git-wip-us.apache.org/repos/asf/hadoop/blob/e87bf171/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/namenode/TestNameNodeMetadataConsistency.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/namenode/TestNameNodeMetadataConsistency.java b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/namenode/TestNameNodeMetadataConsistency.java index 17fcdfb..b97b696 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/namenode/TestNameNodeMetadataConsistency.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/namenode/TestNameNodeMetadataConsistency.java @@ -98,6 +98,7 @@ public class TestNameNodeMetadataConsistency { BlockInfo bInfo = cluster.getNameNode().getNamesystem().getBlockManager ().getStoredBlock(block.getLocalBlock()); cluster.getNameNode().getNamesystem().writeLock(); + bInfo.delete(); cluster.getNameNode().getNamesystem().getBlockManager() .removeBlock(bInfo); cluster.getNameNode().getNamesystem().writeUnlock(); @@ -162,6 +163,7 @@ public class TestNameNodeMetadataConsistency { BlockInfo bInfo = cluster.getNameNode().getNamesystem().getBlockManager ().getStoredBlock(block.getLocalBlock()); cluster.getNameNode().getNamesystem().writeLock(); + bInfo.delete(); cluster.getNameNode().getNamesystem().getBlockManager() .removeBlock(bInfo); cluster.getNameNode().getNamesystem().writeUnlock(); @@ -184,4 +186,4 @@ public class TestNameNodeMetadataConsistency { e.printStackTrace(); } } -} \ No newline at end of file +} --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org For additional commands, e-mail: common-commits-help@hadoop.apache.org