You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by ga...@apache.org on 2011/11/01 19:15:11 UTC
svn commit: r1196185 - in /hbase/trunk: CHANGES.txt
src/main/java/org/apache/hadoop/hbase/ipc/HBaseRPC.java
Author: garyh
Date: Tue Nov 1 18:15:11 2011
New Revision: 1196185
URL: http://svn.apache.org/viewvc?rev=1196185&view=rev
Log:
HBASE-4710 UnknownProtocolException should abort client retries as a DoNotRetryIOException
Modified:
hbase/trunk/CHANGES.txt
hbase/trunk/src/main/java/org/apache/hadoop/hbase/ipc/HBaseRPC.java
Modified: hbase/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hbase/trunk/CHANGES.txt?rev=1196185&r1=1196184&r2=1196185&view=diff
==============================================================================
--- hbase/trunk/CHANGES.txt (original)
+++ hbase/trunk/CHANGES.txt Tue Nov 1 18:15:11 2011
@@ -432,6 +432,7 @@ Release 0.92.0 - Unreleased
HBASE-4613 hbase.util.Threads#threadDumpingIsAlive sleeps 1 second,
slowing down the shutdown by 0.5s
HBASE-4552 multi-CF bulk load is not atomic across column families (Jonathan Hsieh)
+ HBASE-4710 UnknownProtocolException should abort client retries
TESTS
HBASE-4450 test for number of blocks read: to serve as baseline for expected
Modified: hbase/trunk/src/main/java/org/apache/hadoop/hbase/ipc/HBaseRPC.java
URL: http://svn.apache.org/viewvc/hbase/trunk/src/main/java/org/apache/hadoop/hbase/ipc/HBaseRPC.java?rev=1196185&r1=1196184&r2=1196185&view=diff
==============================================================================
--- hbase/trunk/src/main/java/org/apache/hadoop/hbase/ipc/HBaseRPC.java (original)
+++ hbase/trunk/src/main/java/org/apache/hadoop/hbase/ipc/HBaseRPC.java Tue Nov 1 18:15:11 2011
@@ -185,6 +185,11 @@ public class HBaseRPC {
public static class UnknownProtocolException extends DoNotRetryIOException {
private Class<?> protocol;
+ public UnknownProtocolException(String mesg) {
+ // required for unwrapping from a RemoteException
+ super(mesg);
+ }
+
public UnknownProtocolException(Class<?> protocol) {
this(protocol, "Server is not handling protocol "+protocol.getName());
}