HBASE-9138 getHaseIntegrationTestingUtility() is misspelled
git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1541328 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
1427e3a431
commit
2a057457d0
|
@ -114,7 +114,7 @@ public class Action {
|
||||||
|
|
||||||
LOG.info("Moving " + victimRegions.size() + " regions from " + fromServers.size()
|
LOG.info("Moving " + victimRegions.size() + " regions from " + fromServers.size()
|
||||||
+ " servers to " + toServers.size() + " different servers");
|
+ " servers to " + toServers.size() + " different servers");
|
||||||
HBaseAdmin admin = this.context.getHaseIntegrationTestingUtility().getHBaseAdmin();
|
HBaseAdmin admin = this.context.getHBaseIntegrationTestingUtility().getHBaseAdmin();
|
||||||
for (byte[] victimRegion : victimRegions) {
|
for (byte[] victimRegion : victimRegions) {
|
||||||
int targetIx = RandomUtils.nextInt(toServers.size());
|
int targetIx = RandomUtils.nextInt(toServers.size());
|
||||||
admin.move(victimRegion, Bytes.toBytes(toServers.get(targetIx).getServerName()));
|
admin.move(victimRegion, Bytes.toBytes(toServers.get(targetIx).getServerName()));
|
||||||
|
@ -122,7 +122,7 @@ public class Action {
|
||||||
}
|
}
|
||||||
|
|
||||||
protected void forceBalancer() throws Exception {
|
protected void forceBalancer() throws Exception {
|
||||||
HBaseAdmin admin = this.context.getHaseIntegrationTestingUtility().getHBaseAdmin();
|
HBaseAdmin admin = this.context.getHBaseIntegrationTestingUtility().getHBaseAdmin();
|
||||||
boolean result = admin.balancer();
|
boolean result = admin.balancer();
|
||||||
if (!result) {
|
if (!result) {
|
||||||
LOG.error("Balancer didn't succeed");
|
LOG.error("Balancer didn't succeed");
|
||||||
|
@ -139,7 +139,7 @@ public class Action {
|
||||||
this.util = util;
|
this.util = util;
|
||||||
}
|
}
|
||||||
|
|
||||||
public IntegrationTestingUtility getHaseIntegrationTestingUtility() {
|
public IntegrationTestingUtility getHBaseIntegrationTestingUtility() {
|
||||||
return util;
|
return util;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -42,7 +42,7 @@ public class AddColumnAction extends Action {
|
||||||
@Override
|
@Override
|
||||||
public void init(ActionContext context) throws IOException {
|
public void init(ActionContext context) throws IOException {
|
||||||
super.init(context);
|
super.init(context);
|
||||||
this.admin = context.getHaseIntegrationTestingUtility().getHBaseAdmin();
|
this.admin = context.getHBaseIntegrationTestingUtility().getHBaseAdmin();
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|
|
@ -46,7 +46,7 @@ public class ChangeEncodingAction extends Action {
|
||||||
@Override
|
@Override
|
||||||
public void init(ActionContext context) throws IOException {
|
public void init(ActionContext context) throws IOException {
|
||||||
super.init(context);
|
super.init(context);
|
||||||
this.admin = context.getHaseIntegrationTestingUtility().getHBaseAdmin();
|
this.admin = context.getHBaseIntegrationTestingUtility().getHBaseAdmin();
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|
|
@ -47,7 +47,7 @@ public class ChangeVersionsAction extends Action {
|
||||||
@Override
|
@Override
|
||||||
public void init(ActionContext context) throws IOException {
|
public void init(ActionContext context) throws IOException {
|
||||||
super.init(context);
|
super.init(context);
|
||||||
this.admin = context.getHaseIntegrationTestingUtility().getHBaseAdmin();
|
this.admin = context.getHBaseIntegrationTestingUtility().getHBaseAdmin();
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|
|
@ -51,7 +51,7 @@ public class CompactRandomRegionOfTableAction extends Action {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void perform() throws Exception {
|
public void perform() throws Exception {
|
||||||
HBaseTestingUtility util = context.getHaseIntegrationTestingUtility();
|
HBaseTestingUtility util = context.getHBaseIntegrationTestingUtility();
|
||||||
HBaseAdmin admin = util.getHBaseAdmin();
|
HBaseAdmin admin = util.getHBaseAdmin();
|
||||||
boolean major = RandomUtils.nextInt(100) < majorRatio;
|
boolean major = RandomUtils.nextInt(100) < majorRatio;
|
||||||
|
|
||||||
|
|
|
@ -46,7 +46,7 @@ public class CompactTableAction extends Action {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void perform() throws Exception {
|
public void perform() throws Exception {
|
||||||
HBaseTestingUtility util = context.getHaseIntegrationTestingUtility();
|
HBaseTestingUtility util = context.getHBaseIntegrationTestingUtility();
|
||||||
HBaseAdmin admin = util.getHBaseAdmin();
|
HBaseAdmin admin = util.getHBaseAdmin();
|
||||||
boolean major = RandomUtils.nextInt(100) < majorRatio;
|
boolean major = RandomUtils.nextInt(100) < majorRatio;
|
||||||
|
|
||||||
|
|
|
@ -46,7 +46,7 @@ public class FlushRandomRegionOfTableAction extends Action {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void perform() throws Exception {
|
public void perform() throws Exception {
|
||||||
HBaseTestingUtility util = context.getHaseIntegrationTestingUtility();
|
HBaseTestingUtility util = context.getHBaseIntegrationTestingUtility();
|
||||||
HBaseAdmin admin = util.getHBaseAdmin();
|
HBaseAdmin admin = util.getHBaseAdmin();
|
||||||
|
|
||||||
LOG.info("Performing action: Flush random region of table " + tableName);
|
LOG.info("Performing action: Flush random region of table " + tableName);
|
||||||
|
|
|
@ -42,7 +42,7 @@ public class FlushTableAction extends Action {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void perform() throws Exception {
|
public void perform() throws Exception {
|
||||||
HBaseTestingUtility util = context.getHaseIntegrationTestingUtility();
|
HBaseTestingUtility util = context.getHBaseIntegrationTestingUtility();
|
||||||
HBaseAdmin admin = util.getHBaseAdmin();
|
HBaseAdmin admin = util.getHBaseAdmin();
|
||||||
|
|
||||||
LOG.info("Performing action: Flush table " + tableName);
|
LOG.info("Performing action: Flush table " + tableName);
|
||||||
|
|
|
@ -46,7 +46,7 @@ public class MergeRandomAdjacentRegionsOfTableAction extends Action {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void perform() throws Exception {
|
public void perform() throws Exception {
|
||||||
HBaseTestingUtility util = context.getHaseIntegrationTestingUtility();
|
HBaseTestingUtility util = context.getHBaseIntegrationTestingUtility();
|
||||||
HBaseAdmin admin = util.getHBaseAdmin();
|
HBaseAdmin admin = util.getHBaseAdmin();
|
||||||
|
|
||||||
LOG.info("Performing action: Merge random adjacent regions of table " + tableName);
|
LOG.info("Performing action: Merge random adjacent regions of table " + tableName);
|
||||||
|
|
|
@ -50,7 +50,7 @@ public class MoveRandomRegionOfTableAction extends Action {
|
||||||
Thread.sleep(sleepTime);
|
Thread.sleep(sleepTime);
|
||||||
}
|
}
|
||||||
|
|
||||||
HBaseTestingUtility util = context.getHaseIntegrationTestingUtility();
|
HBaseTestingUtility util = context.getHBaseIntegrationTestingUtility();
|
||||||
HBaseAdmin admin = util.getHBaseAdmin();
|
HBaseAdmin admin = util.getHBaseAdmin();
|
||||||
|
|
||||||
LOG.info("Performing action: Move random region of table " + tableName);
|
LOG.info("Performing action: Move random region of table " + tableName);
|
||||||
|
|
|
@ -54,7 +54,7 @@ public class MoveRegionsOfTableAction extends Action {
|
||||||
Thread.sleep(sleepTime);
|
Thread.sleep(sleepTime);
|
||||||
}
|
}
|
||||||
|
|
||||||
HBaseAdmin admin = this.context.getHaseIntegrationTestingUtility().getHBaseAdmin();
|
HBaseAdmin admin = this.context.getHBaseIntegrationTestingUtility().getHBaseAdmin();
|
||||||
Collection<ServerName> serversList = admin.getClusterStatus().getServers();
|
Collection<ServerName> serversList = admin.getClusterStatus().getServers();
|
||||||
ServerName[] servers = serversList.toArray(new ServerName[serversList.size()]);
|
ServerName[] servers = serversList.toArray(new ServerName[serversList.size()]);
|
||||||
|
|
||||||
|
|
|
@ -47,7 +47,7 @@ public class RemoveColumnAction extends Action {
|
||||||
@Override
|
@Override
|
||||||
public void init(ActionContext context) throws IOException {
|
public void init(ActionContext context) throws IOException {
|
||||||
super.init(context);
|
super.init(context);
|
||||||
this.admin = context.getHaseIntegrationTestingUtility().getHBaseAdmin();
|
this.admin = context.getHBaseIntegrationTestingUtility().getHBaseAdmin();
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|
|
@ -42,7 +42,7 @@ public class RestartRsHoldingTableAction extends RestartActionBaseAction {
|
||||||
public void perform() throws Exception {
|
public void perform() throws Exception {
|
||||||
HTable table = null;
|
HTable table = null;
|
||||||
try {
|
try {
|
||||||
Configuration conf = context.getHaseIntegrationTestingUtility().getConfiguration();
|
Configuration conf = context.getHBaseIntegrationTestingUtility().getConfiguration();
|
||||||
table = new HTable(conf, tableName);
|
table = new HTable(conf, tableName);
|
||||||
} catch (IOException e) {
|
} catch (IOException e) {
|
||||||
LOG.debug("Error creating HTable used to get list of region locations.", e);
|
LOG.debug("Error creating HTable used to get list of region locations.", e);
|
||||||
|
|
|
@ -39,7 +39,7 @@ public class SnapshotTableAction extends Action {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void perform() throws Exception {
|
public void perform() throws Exception {
|
||||||
HBaseTestingUtility util = context.getHaseIntegrationTestingUtility();
|
HBaseTestingUtility util = context.getHBaseIntegrationTestingUtility();
|
||||||
String snapshotName = tableName + "-it-" + System.currentTimeMillis();
|
String snapshotName = tableName + "-it-" + System.currentTimeMillis();
|
||||||
HBaseAdmin admin = util.getHBaseAdmin();
|
HBaseAdmin admin = util.getHBaseAdmin();
|
||||||
|
|
||||||
|
|
|
@ -46,7 +46,7 @@ public class SplitRandomRegionOfTableAction extends Action {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void perform() throws Exception {
|
public void perform() throws Exception {
|
||||||
HBaseTestingUtility util = context.getHaseIntegrationTestingUtility();
|
HBaseTestingUtility util = context.getHBaseIntegrationTestingUtility();
|
||||||
HBaseAdmin admin = util.getHBaseAdmin();
|
HBaseAdmin admin = util.getHBaseAdmin();
|
||||||
|
|
||||||
LOG.info("Performing action: Split random region of table " + tableName);
|
LOG.info("Performing action: Split random region of table " + tableName);
|
||||||
|
|
Loading…
Reference in New Issue