1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19 package org.apache.hadoop.hbase.chaos.actions;
20
21 import java.util.List;
22
23 import org.apache.hadoop.hbase.HBaseTestingUtility;
24 import org.apache.hadoop.hbase.HRegionInfo;
25 import org.apache.hadoop.hbase.TableName;
26 import org.apache.hadoop.hbase.chaos.monkies.PolicyBasedChaosMonkey;
27 import org.apache.hadoop.hbase.client.Admin;
28
29
30
31
32 public class SplitRandomRegionOfTableAction extends Action {
33 private final long sleepTime;
34 private final TableName tableName;
35
36 public SplitRandomRegionOfTableAction(TableName tableName) {
37 this(-1, tableName);
38 }
39
40 public SplitRandomRegionOfTableAction(int sleepTime, TableName tableName) {
41 this.sleepTime = sleepTime;
42 this.tableName = tableName;
43 }
44
45 @Override
46 public void perform() throws Exception {
47 HBaseTestingUtility util = context.getHBaseIntegrationTestingUtility();
48 Admin admin = util.getHBaseAdmin();
49
50 LOG.info("Performing action: Split random region of table " + tableName);
51 List<HRegionInfo> regions = admin.getTableRegions(tableName);
52 if (regions == null || regions.isEmpty()) {
53 LOG.info("Table " + tableName + " doesn't have regions to split");
54 return;
55 }
56
57 if (context.isStopping()) {
58 return;
59 }
60
61 HRegionInfo region = PolicyBasedChaosMonkey.selectRandomItem(
62 regions.toArray(new HRegionInfo[regions.size()]));
63 LOG.debug("Splitting region " + region.getRegionNameAsString());
64 try {
65 admin.splitRegion(region.getRegionName());
66 } catch (Exception ex) {
67 LOG.warn("Split failed, might be caused by other chaos: " + ex.getMessage());
68 }
69 if (sleepTime > 0) {
70 Thread.sleep(sleepTime);
71 }
72 }
73 }