Description
DatanodeDescriptor.java
public void resetBlocks() { ... this.invalidateBlocks.clear(); ... } public void clearBlockQueues() { synchronized (invalidateBlocks) { this.invalidateBlocks.clear(); } ... }
It may not be strictly necessary, but why risk it? The invalidateBlocks should be protected in resetBlocks() just like it is in clearBlockQueues()/