Skip to content

Commit

Permalink
fix formatting, typos, update test to match reality
Browse files Browse the repository at this point in the history
  • Loading branch information
PrateekSane committed Nov 5, 2024
1 parent b4478b7 commit 0487705
Show file tree
Hide file tree
Showing 6 changed files with 9 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -108,7 +108,7 @@ public String toString() {
getBytesInFutureBlockGroups())
.append(", PendingDeletionBlocks=").append(
getPendingDeletionBlocks())
.append(" , badlyDistributedBlocks=").append(getBadlyDistributedBlocks());
.append(" , BadlyDistributedBlocks=").append(getBadlyDistributedBlocks());
if (hasHighestPriorityLowRedundancyBlocks()) {
statsBuilder.append(", HighestPriorityLowRedundancyBlocks=")
.append(getHighestPriorityLowRedundancyBlocks());
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -782,7 +782,7 @@ public BlockStoragePolicySuite getStoragePolicySuite() {
return storagePolicySuite;
}

/** get the BlockTokenSecretManager */
/** @return get the BlockTokenSecretManager */
@VisibleForTesting
public BlockTokenSecretManager getBlockTokenSecretManager() {
return blockTokenSecretManager;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -4836,7 +4836,7 @@ ECBlockGroupStats getECBlockGroupStats() {
return new ECBlockGroupStats(getLowRedundancyECBlockGroups(),
getCorruptECBlockGroups(), getMissingECBlockGroups(),
getBytesInFutureECBlockGroups(), getPendingDeletionECBlocks(),
getHighestPriorityLowRedundancyECBlocks());
getBadlyDistributedBlocks(), getHighestPriorityLowRedundancyECBlocks());
}

@Override // FSNamesystemMBean
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -58,7 +58,7 @@ public interface ECBlockGroupsMBean {
long getPendingDeletionECBlocks();

/**
* @return total number of erasure coded block groups.
* Return total number of erasure coded block groups.
*/
long getTotalECBlockGroups();

Check failure on line 63 in hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/metrics/ECBlockGroupsMBean.java

View check run for this annotation

ASF Cloudbees Jenkins ci-hadoop / Apache Yetus

hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/metrics/ECBlockGroupsMBean.java#L63

javadoc: warning: no @return

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -123,7 +123,7 @@ public class DFSAdmin extends FsShell {
private static final Logger LOG = LoggerFactory.getLogger(DFSAdmin.class);

/**
* An abstract class for the execution of a file system command
* An abstract class for the execution of a file system command.
*/
abstract private static class DFSAdminCommand extends Command {
protected DistributedFileSystem dfs;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -179,7 +179,7 @@ public void testBlockPriorities() throws Throwable {
BlockInfo block_very_low_redundancy = genBlockInfo(3);
BlockInfo block_corrupt = genBlockInfo(4);
BlockInfo block_corrupt_repl_one = genBlockInfo(5);
BlockInfo block_badly_distributed = genBlockInfo(6);
BlockInfo blockBadlyDistributed = genBlockInfo(6);

// Add a block with a single entry
assertAdded(queues, block1, 1, 0, 3);
Expand Down Expand Up @@ -227,10 +227,10 @@ public void testBlockPriorities() throws Throwable {
verifyBlockStats(queues, 2, 3, 2, 0, 0, 0, 0, 1);

// insert a block with too many replicas to make badly distributed
assertAdded(queues, block_badly_distributed, 2, 0, 1);
assertInLevel(queues, block_badly_distributed,
assertAdded(queues, blockBadlyDistributed, 2, 0, 1);
assertInLevel(queues, blockBadlyDistributed,
LowRedundancyBlocks.QUEUE_REPLICAS_BADLY_DISTRIBUTED);
verifyBlockStats(queues, 2, 3, 2, 0, 0, 0, 0, 2);
verifyBlockStats(queues, 3, 3, 2, 0, 0, 0, 0, 2);
}

@Test
Expand Down

0 comments on commit 0487705

Please sign in to comment.