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 index d719e937f2e..a73266795ea 100644 --- 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 @@ -117,6 +117,8 @@ class LowRedundancyBlocks implements Iterable { corruptReplicationOneBlocks.reset(); lowRedundancyECBlockGroups.reset(); corruptECBlockGroups.reset(); + highestPriorityLowRedundancyReplicatedBlocks.reset(); + highestPriorityLowRedundancyECBlocks.reset(); } /** Return the total number of insufficient redundancy blocks. */