diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/DatanodeDescriptor.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/DatanodeDescriptor.java index 4b87fd43534..57348a3a616 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/DatanodeDescriptor.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/DatanodeDescriptor.java @@ -644,14 +644,14 @@ public class DatanodeDescriptor extends DatanodeInfo { } /** - * The number of work items that are pending to be replicated + * The number of work items that are pending to be replicated. */ int getNumberOfBlocksToBeReplicated() { return pendingReplicationWithoutTargets + replicateBlocks.size(); } /** - * The number of work items that are pending to be replicated + * The number of work items that are pending to be reconstructed. */ @VisibleForTesting public int getNumberOfBlocksToBeErasureCoded() {