diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/client/ServerCallable.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/client/ServerCallable.java index 47f699a..c95b581 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/client/ServerCallable.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/client/ServerCallable.java @@ -27,6 +27,8 @@ import java.util.ArrayList; import java.util.List; import java.util.concurrent.Callable; +import org.apache.commons.logging.Log; +import org.apache.commons.logging.LogFactory; import org.apache.hadoop.classification.InterfaceAudience; import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.conf.Configuration; @@ -54,6 +56,8 @@ import com.google.protobuf.ServiceException; @InterfaceAudience.Public @InterfaceStability.Stable public abstract class ServerCallable implements Callable { + private static final Log LOG = LogFactory.getLog(ServerCallable.class); + protected final HConnection connection; protected final byte [] tableName; protected final byte [] row; @@ -184,6 +188,10 @@ public abstract class ServerCallable implements Callable { new RetriesExhaustedException.ThrowableWithExtraContext(t, System.currentTimeMillis(), toString()); exceptions.add(qt); + String message = String.format("Exception caught during try #%d (out of %d):", tries+1, + numRetries); + LOG.info(message, t); + if (tries == numRetries - 1) { throw new RetriesExhaustedException(tries, exceptions); }