You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by st...@apache.org on 2012/08/25 07:32:05 UTC
svn commit: r1377217 -
/hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
Author: stack
Date: Sat Aug 25 05:32:05 2012
New Revision: 1377217
URL: http://svn.apache.org/viewvc?rev=1377217&view=rev
Log:
HBASE-6662 Region server incorrectly reports its own address as master's address
Modified:
hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
Modified: hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java?rev=1377217&r1=1377216&r2=1377217&view=diff
==============================================================================
--- hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java (original)
+++ hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java Sat Aug 25 05:32:05 2012
@@ -1780,6 +1780,7 @@ public class HRegionServer implements HR
ServerName masterServerName = null;
long previousLogTime = 0;
HMasterRegionInterface master = null;
+ InetSocketAddress masterIsa = null;
while (keepLooping() && master == null) {
masterServerName = this.masterAddressManager.getMasterAddress();
if (masterServerName == null) {
@@ -1795,7 +1796,7 @@ public class HRegionServer implements HR
continue;
}
- InetSocketAddress isa =
+ masterIsa =
new InetSocketAddress(masterServerName.getHostname(), masterServerName.getPort());
LOG.info("Attempting connect to Master server at " +
@@ -1805,7 +1806,7 @@ public class HRegionServer implements HR
// should retry indefinitely.
master = (HMasterRegionInterface) HBaseRPC.waitForProxy(
HMasterRegionInterface.class, HMasterRegionInterface.VERSION,
- isa, this.conf, -1,
+ masterIsa, this.conf, -1,
this.rpcTimeout, this.rpcTimeout);
} catch (IOException e) {
e = e instanceof RemoteException ?
@@ -1827,7 +1828,7 @@ public class HRegionServer implements HR
}
}
}
- LOG.info("Connected to master at " + isa);
+ LOG.info("Connected to master at " + masterIsa);
this.hbaseMaster = master;
return masterServerName;
}