HBASE-22047 LeaseException in Scan should be retried
Signed-off-by: stack <stack@apache.org> Conflicts: hbase-client/src/main/java/org/apache/hadoop/hbase/client/ClientScanner.java
This commit is contained in:
parent
ac807d7fe5
commit
9058bb0c59
@ -33,6 +33,7 @@ import org.apache.hadoop.conf.Configuration;
|
||||
import org.apache.hadoop.hbase.DoNotRetryIOException;
|
||||
import org.apache.hadoop.hbase.HConstants;
|
||||
import org.apache.hadoop.hbase.HRegionInfo;
|
||||
import org.apache.hadoop.hbase.regionserver.LeaseException;
|
||||
import org.apache.hadoop.hbase.NotServingRegionException;
|
||||
import org.apache.hadoop.hbase.TableName;
|
||||
import org.apache.hadoop.hbase.UnknownScannerException;
|
||||
@ -364,7 +365,7 @@ public abstract class ClientScanner extends AbstractClientScanner {
|
||||
if ((cause != null && cause instanceof NotServingRegionException) ||
|
||||
(cause != null && cause instanceof RegionServerStoppedException) ||
|
||||
e instanceof OutOfOrderScannerNextException || e instanceof UnknownScannerException ||
|
||||
e instanceof ScannerResetException) {
|
||||
e instanceof ScannerResetException || e instanceof LeaseException) {
|
||||
// Pass. It is easier writing the if loop test as list of what is allowed rather than
|
||||
// as a list of what is not allowed... so if in here, it means we do not throw.
|
||||
if (retriesLeft <= 0) {
|
||||
|
Loading…
x
Reference in New Issue
Block a user