diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncRpcRetryingCaller.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncRpcRetryingCaller.java index dcf7aa154f9..586e7d52e07 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncRpcRetryingCaller.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncRpcRetryingCaller.java @@ -126,7 +126,7 @@ public abstract class AsyncRpcRetryingCaller { resetController(controller, callTimeoutNs, priority); } - private void tryScheduleRetry(Throwable error, Consumer updateCachedLocation) { + private void tryScheduleRetry(Throwable error) { long pauseNsToUse = error instanceof CallQueueTooBigException ? pauseForCQTBENs : pauseNs; long delayNs; if (operationTimeoutNs > 0) { @@ -192,19 +192,21 @@ public abstract class AsyncRpcRetryingCaller { future.completeExceptionally(e); } else { // failed to test whether the table is disabled, not a big deal, continue retrying - tryScheduleRetry(error, updateCachedLocation); + tryScheduleRetry(error); } return; } if (disabled) { future.completeExceptionally(new TableNotEnabledException(tableName.get())); } else { - tryScheduleRetry(error, updateCachedLocation); + tryScheduleRetry(error); } }); + } else { + tryScheduleRetry(error); } } else { - tryScheduleRetry(error, updateCachedLocation); + tryScheduleRetry(error); } }