|
@@ -2916,7 +2916,12 @@ public class FSNamesystem implements Namesystem, FSClusterStats,
|
|
getEditLog().logSync();
|
|
getEditLog().logSync();
|
|
removeBlocks(collectedBlocks); // Incremental deletion of blocks
|
|
removeBlocks(collectedBlocks); // Incremental deletion of blocks
|
|
collectedBlocks.clear();
|
|
collectedBlocks.clear();
|
|
- dir.removeFromInodeMap(removedINodes);
|
|
|
|
|
|
+ dir.writeLock();
|
|
|
|
+ try {
|
|
|
|
+ dir.removeFromInodeMap(removedINodes);
|
|
|
|
+ } finally {
|
|
|
|
+ dir.writeUnlock();
|
|
|
|
+ }
|
|
removedINodes.clear();
|
|
removedINodes.clear();
|
|
if (NameNode.stateChangeLog.isDebugEnabled()) {
|
|
if (NameNode.stateChangeLog.isDebugEnabled()) {
|
|
NameNode.stateChangeLog.debug("DIR* Namesystem.delete: "
|
|
NameNode.stateChangeLog.debug("DIR* Namesystem.delete: "
|