diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/LocalHBaseCluster.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/LocalHBaseCluster.java index eacba6f..dbf47d3 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/LocalHBaseCluster.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/LocalHBaseCluster.java @@ -168,6 +168,7 @@ public class LocalHBaseCluster { return addRegionServer(new Configuration(conf), this.regionThreads.size()); } + @SuppressWarnings("unchecked") public JVMClusterUtil.RegionServerThread addRegionServer( Configuration config, final int index) throws IOException { @@ -181,8 +182,9 @@ public class LocalHBaseCluster { CoordinatedStateManager cp = CoordinatedStateManagerFactory.getCoordinatedStateManager(conf); JVMClusterUtil.RegionServerThread rst = - JVMClusterUtil.createRegionServerThread(config, cp, - this.regionServerClass, index); + JVMClusterUtil.createRegionServerThread(config, cp, (Class) conf + .getClass(HConstants.REGION_SERVER_IMPL, this.regionServerClass), index); + this.regionThreads.add(rst); return rst; } @@ -262,6 +264,13 @@ public class LocalHBaseCluster { } /** + * @return the Configuration used by this LocalHBaseCluster + */ + public Configuration getConfiguration() { + return this.conf; + } + + /** * Wait for the specified region server to stop * Removes this thread from list of running threads. * @param serverNumber