HBASE-25329 Dump ritsOverThreshold in logs (#2761)
Signed-off-by: Bharath Vissapragada <bharathv@apache.org> Signed-off-by: Viraj Jasani <vjasani@apache.org>
This commit is contained in:
parent
13dd54af89
commit
dfefff7e59
|
@ -1425,6 +1425,13 @@ public class AssignmentManager {
|
|||
this.statTimestamp = EnvironmentEdgeManager.currentTime();
|
||||
update(regionStates.getRegionsStateInTransition(), statTimestamp);
|
||||
update(regionStates.getRegionFailedOpen(), statTimestamp);
|
||||
|
||||
if (LOG.isDebugEnabled() && ritsOverThreshold != null && !ritsOverThreshold.isEmpty()) {
|
||||
LOG.debug("RITs over threshold: {}",
|
||||
ritsOverThreshold.entrySet().stream()
|
||||
.map(e -> e.getKey() + ":" + e.getValue().getState().name())
|
||||
.collect(Collectors.joining("\n")));
|
||||
}
|
||||
}
|
||||
|
||||
private void update(final Collection<RegionState> regions, final long currentTime) {
|
||||
|
|
Loading…
Reference in New Issue