From fc95ee9a24ae7844efc97d903201039f04019c6d Mon Sep 17 00:00:00 2001 From: Mikhail Antonov Date: Fri, 4 Nov 2016 17:30:17 -0700 Subject: [PATCH] HBASE-17032 CallQueueTooBigException and CallDroppedException should not be triggering PFFE --- .../org/apache/hadoop/hbase/client/PreemptiveFastFailInterceptor.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/PreemptiveFastFailInterceptor.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/PreemptiveFastFailInterceptor.java index fed87c1..7ac5c45 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/PreemptiveFastFailInterceptor.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/PreemptiveFastFailInterceptor.java @@ -174,9 +174,7 @@ class PreemptiveFastFailInterceptor extends RetryingCallerInterceptor { Throwable t2 = ClientExceptionsUtil.translatePFFE(t1); boolean isLocalException = !(t2 instanceof RemoteException); - if ((isLocalException && ClientExceptionsUtil.isConnectionException(t2)) || - ClientExceptionsUtil.isCallQueueTooBigException(t2) || - ClientExceptionsUtil.isCallDroppedException(t2)) { + if ((isLocalException && ClientExceptionsUtil.isConnectionException(t2))) { couldNotCommunicateWithServer.setValue(true); guaranteedClientSideOnly.setValue(!(t2 instanceof CallTimeoutException)); handleFailureToServer(serverName, t2); -- 2.8.0-rc2