diff --git src/main/java/org/apache/hadoop/hbase/client/ServerCallable.java src/main/java/org/apache/hadoop/hbase/client/ServerCallable.java index a879604..381ac74 100644 --- src/main/java/org/apache/hadoop/hbase/client/ServerCallable.java +++ src/main/java/org/apache/hadoop/hbase/client/ServerCallable.java @@ -28,6 +28,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; @@ -55,6 +57,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; @@ -185,6 +189,10 @@ public abstract class ServerCallable implements Callable { new RetriesExhaustedException.ThrowableWithExtraContext(t, System.currentTimeMillis(), toString()); exceptions.add(qt); + if (LOG.isDebugEnabled()) { + String message = String.format("Exception during try #%d (out of %d):", tries+1, numRetries); + LOG.debug(message, t); + } if (tries == numRetries - 1) { throw new RetriesExhaustedException(tries, exceptions); }