You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by li...@apache.org on 2014/04/02 22:49:09 UTC
svn commit: r1584162 [3/5] - in /hbase/branches/0.89-fb/src:
main/java/org/apache/hadoop/hbase/client/
test/java/org/apache/hadoop/hbase/client/
Modified: hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/client/ServerCallable.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/client/ServerCallable.java?rev=1584162&r1=1584161&r2=1584162&view=diff
==============================================================================
--- hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/client/ServerCallable.java (original)
+++ hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/client/ServerCallable.java Wed Apr 2 20:49:09 2014
@@ -127,12 +127,12 @@ public abstract class ServerCallable<T>
}
public void updateFailureInfoForServer(boolean didTry, boolean couldNotCommunicate) {
- ((HConnectionManager.TableServers)connection).updateFailureInfoForServer(
+ ((TableServers)connection).updateFailureInfoForServer(
getServerAddress(), didTry, couldNotCommunicate);
}
public void handleThrowable(Throwable t, MutableBoolean couldNotCommunicateWithServer) throws Exception {
- ((HConnectionManager.TableServers)connection).handleThrowable(t, this, couldNotCommunicateWithServer);
+ ((TableServers)connection).handleThrowable(t, this, couldNotCommunicateWithServer);
}
public void readHeader() {