diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/FailedServers.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/FailedServers.java index 868cdc681b..e635367158 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/FailedServers.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/FailedServers.java @@ -25,6 +25,8 @@ import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.classification.InterfaceAudience; import org.apache.hadoop.hbase.util.EnvironmentEdgeManager; import org.apache.hadoop.hbase.util.Pair; +import org.apache.commons.logging.Log; +import org.apache.commons.logging.LogFactory; /** * A class to manage a list of servers that failed recently. @@ -33,6 +35,7 @@ import org.apache.hadoop.hbase.util.Pair; public class FailedServers { private final LinkedList> failedServers = new LinkedList<>(); private final int recheckServersTimeout; + private static final Log LOG = LogFactory.getLog(FailedServers.class); public FailedServers(Configuration conf) { this.recheckServersTimeout = conf.getInt( @@ -45,6 +48,9 @@ public class FailedServers { public synchronized void addToFailedServers(InetSocketAddress address) { final long expiry = EnvironmentEdgeManager.currentTime() + recheckServersTimeout; failedServers.addFirst(new Pair<>(expiry, address.toString())); + if (LOG.isDebugEnabled()) { + LOG.debug("Added failed server with expiry " + expiry + " and address " + address.toString() + " to list"); + } } /**