1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18 package org.apache.hadoop.hbase.procedure;
19
20 import java.io.IOException;
21 import java.util.HashMap;
22
23 import org.apache.commons.logging.Log;
24 import org.apache.commons.logging.LogFactory;
25 import org.apache.hadoop.conf.Configuration;
26 import org.apache.hadoop.hbase.HBaseTestingUtility;
27 import org.apache.hadoop.hbase.SmallTests;
28 import org.apache.hadoop.hbase.client.HBaseAdmin;
29 import org.junit.AfterClass;
30 import org.junit.BeforeClass;
31 import org.junit.Test;
32 import org.junit.experimental.categories.Category;
33
34 @Category(SmallTests.class)
35 public class TestProcedureManager {
36
37 static final Log LOG = LogFactory.getLog(TestProcedureManager.class);
38 private static final int NUM_RS = 2;
39 private static HBaseTestingUtility util = new HBaseTestingUtility();
40
41 @BeforeClass
42 public static void setupBeforeClass() throws Exception {
43
44 Configuration conf = util.getConfiguration();
45
46 conf.set(ProcedureManagerHost.MASTER_PROCEUDRE_CONF_KEY,
47 SimpleMasterProcedureManager.class.getName());
48 conf.set(ProcedureManagerHost.REGIONSERVER_PROCEDURE_CONF_KEY,
49 SimpleRSProcedureManager.class.getName());
50
51 util.startMiniCluster(NUM_RS);
52 }
53
54 @AfterClass
55 public static void tearDownAfterClass() throws Exception {
56 util.shutdownMiniCluster();
57 }
58
59 @Test
60 public void testSimpleProcedureManager() throws IOException {
61 HBaseAdmin admin = util.getHBaseAdmin();
62
63 admin.execProcedure(SimpleMasterProcedureManager.SIMPLE_SIGNATURE,
64 "mytest", new HashMap<String, String>());
65 }
66 }