diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/DumpClusterStatusAction.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/DumpClusterStatusAction.java index dfb506d6922..d3ad31441e4 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/DumpClusterStatusAction.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/DumpClusterStatusAction.java @@ -19,6 +19,13 @@ package org.apache.hadoop.hbase.chaos.actions; import java.io.IOException; +import java.util.Collections; +import java.util.HashSet; +import java.util.Set; +import java.util.stream.Collectors; +import org.apache.hadoop.hbase.ClusterMetrics; +import org.apache.hadoop.hbase.ServerName; +import org.apache.hadoop.hbase.net.Address; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -28,18 +35,69 @@ import org.slf4j.LoggerFactory; public class DumpClusterStatusAction extends Action { private static final Logger LOG = LoggerFactory.getLogger(DumpClusterStatusAction.class); - @Override protected Logger getLogger() { + private Set
initialRegionServers; + + @Override + protected Logger getLogger() { return LOG; } @Override public void init(ActionContext context) throws IOException { super.init(context); + initialRegionServers = collectKnownRegionServers(initialStatus); } @Override public void perform() throws Exception { getLogger().debug("Performing action: Dump cluster status"); - getLogger().info("Cluster status\n" + cluster.getClusterMetrics()); + final ClusterMetrics currentMetrics = cluster.getClusterMetrics(); + getLogger().info("Cluster status\n{}", currentMetrics); + reportMissingRegionServers(currentMetrics); + reportNewRegionServers(currentMetrics); + } + + /** + * Build a set of all the host:port pairs of region servers known to this cluster. + */ + private static Set
collectKnownRegionServers(final ClusterMetrics clusterMetrics) { + final Set
regionServers = clusterMetrics.getLiveServerMetrics() + .keySet() + .stream() + .map(ServerName::getAddress) + .collect(Collectors.toSet()); + clusterMetrics.getDeadServerNames() + .stream() + .map(ServerName::getAddress) + .forEach(regionServers::add); + return Collections.unmodifiableSet(regionServers); + } + + private void reportMissingRegionServers(final ClusterMetrics clusterMetrics) { + final Set
regionServers = collectKnownRegionServers(clusterMetrics); + final Set
missingRegionServers = new HashSet<>(initialRegionServers); + missingRegionServers.removeAll(regionServers); + if (!missingRegionServers.isEmpty()) { + final StringBuilder stringBuilder = new StringBuilder() + .append("region server(s) are missing from this cluster report"); + missingRegionServers.stream() + .sorted() + .forEach(address -> stringBuilder.append("\n ").append(address)); + getLogger().warn(stringBuilder.toString()); + } + } + + private void reportNewRegionServers(final ClusterMetrics clusterMetrics) { + final Set
regionServers = collectKnownRegionServers(clusterMetrics); + final Set
newRegionServers = new HashSet<>(regionServers); + newRegionServers.removeAll(initialRegionServers); + if (!newRegionServers.isEmpty()) { + final StringBuilder stringBuilder = new StringBuilder() + .append("region server(s) are new for this cluster report"); + newRegionServers.stream() + .sorted() + .forEach(address -> stringBuilder.append("\n ").append(address)); + getLogger().warn(stringBuilder.toString()); + } } }