Skip to content

Commit

Permalink
HBASE-26969: Eliminate MOB renames when SFT is enabled
Browse files Browse the repository at this point in the history
improve logging
  • Loading branch information
BukrosSzabolcs committed Jun 9, 2022
1 parent feb7012 commit 79e15bf
Showing 1 changed file with 10 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -167,12 +167,16 @@ public RSMobFileCleanerChore() {
}
}

LOG.debug("Found: {} active mob refs for table={}",
referencedMOBs.values().stream().map(inner -> inner.values())
.flatMap(lists -> lists.stream()).mapToInt(lists -> lists.size()).sum(),
htd.getTableName().getNameAsString());
referencedMOBs.values().stream().forEach(innerMap -> innerMap.values().stream()
.forEach(mobFileList -> mobFileList.stream().forEach(LOG::trace)));
if (LOG.isDebugEnabled()) {
LOG.debug("Found: {} active mob refs for table={}",
referencedMOBs.values().stream().map(inner -> inner.values())
.flatMap(lists -> lists.stream()).mapToInt(lists -> lists.size()).sum(),
htd.getTableName().getNameAsString());
}
if (LOG.isTraceEnabled()) {
referencedMOBs.values().stream().forEach(innerMap -> innerMap.values().stream()
.forEach(mobFileList -> mobFileList.stream().forEach(LOG::trace)));
}

//collect regions referencing MOB files belonging to the current rs
Set<String> regionsCovered = new HashSet<>();
Expand Down

0 comments on commit 79e15bf

Please sign in to comment.