Skip to content

Commit

Permalink
fix build error
Browse files Browse the repository at this point in the history
  • Loading branch information
VicoWu committed Jul 4, 2024
1 parent 3ca9fec commit c93a0ce
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -2131,7 +2131,7 @@ int scheduleReconstructionWorkForBlocks(int blocksToProcess, boolean resetIterat
// Step 1: categorize at-risk blocks into replication and EC tasks
try {
synchronized (neededReconstruction) {
for (; blocksToProcess > 0 && priority < neededReconstruction.LEVEL; priority++) {
for (; blocksToProcess > 0 && priority < LowRedundancyBlocks.LEVEL; priority++) {
List<BlockInfo> blocks = new ArrayList<>();
int processed = neededReconstruction.
chooseLowRedundancyBlocksForPriority(priority, blocksToProcess, blocks);
Expand All @@ -2151,7 +2151,7 @@ int scheduleReconstructionWorkForBlocks(int blocksToProcess, boolean resetIterat
} finally {
namesystem.writeUnlock("generateReconstructionWorkForBlocks");
}
if (priority == LEVEL || resetIterators) {
if (priority == LowRedundancyBlocks.LEVEL || resetIterators) {
// Reset all bookmarks because there were no recently added blocks.
neededReconstruction.resetIterators();
}
Expand Down

0 comments on commit c93a0ce

Please sign in to comment.