synchronized all remove methods in LowRedundancyBlocks.

zhangshuyan0 · zhangshuyan0 · commit 6f00130776b6 · 2023-03-06T10:25:28.000+08:00
diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/LowRedundancyBlocks.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/LowRedundancyBlocks.java
@@ -373,7 +373,7 @@ synchronized boolean remove(BlockInfo block, int priLevel) {
     return remove(block, priLevel, block.getReplication());
   }
 
-  boolean remove(BlockInfo block, int priLevel, int oldExpectedReplicas) {
+  synchronized boolean remove(BlockInfo block, int priLevel, int oldExpectedReplicas) {
     if(priLevel >= 0 && priLevel < LEVEL
         && priorityQueues.get(priLevel).remove(block)) {
       NameNode.blockStateChangeLog.debug(

Original file line number	Diff line number	Diff line change
`@@ -373,7 +373,7 @@ synchronized boolean remove(BlockInfo block, int priLevel) {`
`373`	`373`	`return remove(block, priLevel, block.getReplication());`
`374`	`374`	`}`
`375`	`375`
`376`		`- boolean remove(BlockInfo block, int priLevel, int oldExpectedReplicas) {`
	`376`	`+ synchronized boolean remove(BlockInfo block, int priLevel, int oldExpectedReplicas) {`
`377`	`377`	`if(priLevel >= 0 && priLevel < LEVEL`
`378`	`378`	`&& priorityQueues.get(priLevel).remove(block)) {`
`379`	`379`	`NameNode.blockStateChangeLog.debug(`