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

HBASE-15824 LocalHBaseCluster gets bind exception in master info port

This commit is contained in:
Enis Soztutar 2016-05-15 23:02:11 -07:00
parent 084b036cb2
commit c3223a59ff
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
hbase-server/src/main/java/org/apache/hadoop/hbase/LocalHBaseCluster.java
View File

@ -144,6 +144,9 @@ public class LocalHBaseCluster {
// Always have masters and regionservers come up on port '0' so we don't // Always have masters and regionservers come up on port '0' so we don't
// clash over default ports. // clash over default ports.
conf.set(HConstants.MASTER_PORT, "0"); conf.set(HConstants.MASTER_PORT, "0");
if (conf.getInt(HConstants.MASTER_INFO_PORT, 0) != -1) {
conf.set(HConstants.MASTER_INFO_PORT, "0");
}
conf.set(HConstants.REGIONSERVER_PORT, "0"); conf.set(HConstants.REGIONSERVER_PORT, "0");
if (conf.getInt(HConstants.REGIONSERVER_INFO_PORT, 0) != -1) { if (conf.getInt(HConstants.REGIONSERVER_INFO_PORT, 0) != -1) {
conf.set(HConstants.REGIONSERVER_INFO_PORT, "0"); conf.set(HConstants.REGIONSERVER_INFO_PORT, "0");
@ -196,6 +199,7 @@ public class LocalHBaseCluster {
throws IOException, InterruptedException { throws IOException, InterruptedException {
return user.runAs( return user.runAs(
new PrivilegedExceptionAction<JVMClusterUtil.RegionServerThread>() { new PrivilegedExceptionAction<JVMClusterUtil.RegionServerThread>() {
@Override
public JVMClusterUtil.RegionServerThread run() throws Exception { public JVMClusterUtil.RegionServerThread run() throws Exception {
return addRegionServer(config, index); return addRegionServer(config, index);
} }
@ -228,6 +232,7 @@ public class LocalHBaseCluster {
throws IOException, InterruptedException { throws IOException, InterruptedException {
return user.runAs( return user.runAs(
new PrivilegedExceptionAction<JVMClusterUtil.MasterThread>() { new PrivilegedExceptionAction<JVMClusterUtil.MasterThread>() {
@Override
public JVMClusterUtil.MasterThread run() throws Exception { public JVMClusterUtil.MasterThread run() throws Exception {
return addMaster(c, index); return addMaster(c, index);
} }