diff --git a/hbase-endpoint/src/test/java/org/apache/hadoop/hbase/coprocessor/TestCoprocessorServiceBackwardCompatibility.java b/hbase-endpoint/src/test/java/org/apache/hadoop/hbase/coprocessor/TestCoprocessorServiceBackwardCompatibility.java index c2ff36e..2c1d051 100644 --- a/hbase-endpoint/src/test/java/org/apache/hadoop/hbase/coprocessor/TestCoprocessorServiceBackwardCompatibility.java +++ b/hbase-endpoint/src/test/java/org/apache/hadoop/hbase/coprocessor/TestCoprocessorServiceBackwardCompatibility.java @@ -74,11 +74,11 @@ public class TestCoprocessorServiceBackwardCompatibility { @AfterClass public static void tearDownAfterClass() throws Exception { - TEST_UTIL.shutdownMiniCluster(); } @Test public void testCoprocessorServiceLoadedByMaster() throws Exception { + DummyCoprocessorService.numCalls = 0; CONF.setStrings(CoprocessorHost.MASTER_COPROCESSOR_CONF_KEY, DummyCoprocessorService.class.getName()); TEST_UTIL.startMiniCluster(); @@ -88,10 +88,12 @@ public class TestCoprocessorServiceBackwardCompatibility { DummyRequest.getDefaultInstance(), DummyResponse.getDefaultInstance()); assertEquals(1, DummyCoprocessorService.numCalls); + TEST_UTIL.shutdownMiniCluster(); } @Test public void testCoprocessorServiceLoadedByRegionServer() throws Exception { + DummyCoprocessorService.numCalls = 0; CONF.setStrings(CoprocessorHost.REGIONSERVER_COPROCESSOR_CONF_KEY, DummyCoprocessorService.class.getName()); TEST_UTIL.startMiniCluster(); @@ -100,10 +102,12 @@ public class TestCoprocessorServiceBackwardCompatibility { DummyCoprocessorService.getDescriptor().findMethodByName("dummyCall"), null, DummyRequest.getDefaultInstance(), DummyResponse.getDefaultInstance()); assertEquals(1, DummyCoprocessorService.numCalls); + TEST_UTIL.shutdownMiniCluster(); } @Test public void testCoprocessorServiceLoadedByRegion() throws Throwable { + DummyCoprocessorService.numCalls = 0; CONF.setStrings(CoprocessorHost.REGION_COPROCESSOR_CONF_KEY, DummyCoprocessorService.class.getName()); TEST_UTIL.startMiniCluster(); @@ -112,5 +116,6 @@ public class TestCoprocessorServiceBackwardCompatibility { DummyRequest.getDefaultInstance(), Bytes.toBytes(""), Bytes.toBytes(""), DummyResponse.getDefaultInstance()); assertEquals(1, DummyCoprocessorService.numCalls); + TEST_UTIL.shutdownMiniCluster(); } }