Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-14041 Do not clear MetaCache if a ThrottlingException is thrown 

Signed-off-by: Sean Busbey <busbey@apache.org>
This commit is contained in:
terence.yoo 2015-07-09 13:43:37 +09:00 committed by Sean Busbey
parent 25f7e804cd
commit a63e3ac83f
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionImplementation.java
View File

@ -56,6 +56,7 @@ import org.apache.hadoop.hbase.protobuf.generated.ClientProtos;
import org.apache.hadoop.hbase.protobuf.generated.MasterProtos; import org.apache.hadoop.hbase.protobuf.generated.MasterProtos;
import org.apache.hadoop.hbase.protobuf.generated.MasterProtos.IsBalancerEnabledRequest; import org.apache.hadoop.hbase.protobuf.generated.MasterProtos.IsBalancerEnabledRequest;
import org.apache.hadoop.hbase.protobuf.generated.MasterProtos.IsBalancerEnabledResponse; import org.apache.hadoop.hbase.protobuf.generated.MasterProtos.IsBalancerEnabledResponse;
import org.apache.hadoop.hbase.quotas.ThrottlingException;
import org.apache.hadoop.hbase.regionserver.RegionServerStoppedException; import org.apache.hadoop.hbase.regionserver.RegionServerStoppedException;
import org.apache.hadoop.hbase.security.User; import org.apache.hadoop.hbase.security.User;
import org.apache.hadoop.hbase.util.Bytes; import org.apache.hadoop.hbase.util.Bytes;
@ -263,7 +264,8 @@ class ConnectionImplementation implements ClusterConnection, Closeable {
* - hadoop.ipc wrapped exceptions * - hadoop.ipc wrapped exceptions
* - nested exceptions * - nested exceptions
* *
* Looks for: RegionMovedException / RegionOpeningException / RegionTooBusyException * Looks for: RegionMovedException / RegionOpeningException / RegionTooBusyException /
* ThrottlingException
* @return null if we didn't find the exception, the exception otherwise. * @return null if we didn't find the exception, the exception otherwise.
*/ */
public static Throwable findException(Object exception) { public static Throwable findException(Object exception) {
@ -273,7 +275,7 @@ class ConnectionImplementation implements ClusterConnection, Closeable {
Throwable cur = (Throwable) exception; Throwable cur = (Throwable) exception;
while (cur != null) { while (cur != null) {
if (cur instanceof RegionMovedException || cur instanceof RegionOpeningException if (cur instanceof RegionMovedException || cur instanceof RegionOpeningException
|| cur instanceof RegionTooBusyException) { || cur instanceof RegionTooBusyException || cur instanceof ThrottlingException) {
return cur; return cur;
} }
if (cur instanceof RemoteException) { if (cur instanceof RemoteException) {
@ -1840,7 +1842,8 @@ class ConnectionImplementation implements ClusterConnection, Closeable {
HRegionInfo regionInfo = oldLocation.getRegionInfo(); HRegionInfo regionInfo = oldLocation.getRegionInfo();
Throwable cause = findException(exception); Throwable cause = findException(exception);
if (cause != null) { if (cause != null) {
if (cause instanceof RegionTooBusyException || cause instanceof RegionOpeningException) { if (cause instanceof RegionTooBusyException || cause instanceof RegionOpeningException
|| cause instanceof ThrottlingException) {
// We know that the region is still on this region server // We know that the region is still on this region server
return; return;
} }