Index: hbase-examples/src/test/java/org/apache/hadoop/hbase/coprocessor/example/TestBulkDeleteProtocol.java =================================================================== --- hbase-examples/src/test/java/org/apache/hadoop/hbase/coprocessor/example/TestBulkDeleteProtocol.java (revision 1452424) +++ hbase-examples/src/test/java/org/apache/hadoop/hbase/coprocessor/example/TestBulkDeleteProtocol.java (working copy) @@ -53,6 +53,7 @@ import org.junit.AfterClass; import org.junit.BeforeClass; import org.junit.Test; +import org.junit.Ignore; import org.junit.experimental.categories.Category; @Category(MediumTests.class) @@ -76,7 +77,7 @@ TEST_UTIL.shutdownMiniCluster(); } - @Test + @Ignore @Test public void testBulkDeleteEndpoint() throws Throwable { byte[] tableName = Bytes.toBytes("testBulkDeleteEndpoint"); HTable ht = createTable(tableName); @@ -98,7 +99,7 @@ ht.close(); } - @Test + @Ignore @Test public void testBulkDeleteEndpointWhenRowBatchSizeLessThanRowsToDeleteFromARegion() throws Throwable { byte[] tableName = Bytes @@ -126,10 +127,10 @@ final DeleteType deleteType, final Long timeStamp) throws Throwable { HTable ht = new HTable(TEST_UTIL.getConfiguration(), tableName); long noOfDeletedRows = 0L; - Batch.Call callable = + Batch.Call callable = new Batch.Call() { ServerRpcController controller = new ServerRpcController(); - BlockingRpcCallback rpcCallback = + BlockingRpcCallback rpcCallback = new BlockingRpcCallback(); public BulkDeleteResponse call(BulkDeleteService service) throws IOException { @@ -153,7 +154,7 @@ return noOfDeletedRows; } - @Test + @Ignore @Test public void testBulkDeleteWithConditionBasedDelete() throws Throwable { byte[] tableName = Bytes.toBytes("testBulkDeleteWithConditionBasedDelete"); HTable ht = createTable(tableName); @@ -183,7 +184,7 @@ ht.close(); } - @Test + @Ignore @Test public void testBulkDeleteColumn() throws Throwable { byte[] tableName = Bytes.toBytes("testBulkDeleteColumn"); HTable ht = createTable(tableName); @@ -212,7 +213,7 @@ ht.close(); } - @Test + @Ignore @Test public void testBulkDeleteFamily() throws Throwable { byte[] tableName = Bytes.toBytes("testBulkDeleteFamily"); HTableDescriptor htd = new HTableDescriptor(tableName); @@ -243,7 +244,7 @@ ht.close(); } - @Test + @Ignore @Test public void testBulkDeleteColumnVersion() throws Throwable { byte[] tableName = Bytes.toBytes("testBulkDeleteColumnVersion"); HTable ht = createTable(tableName); @@ -291,7 +292,7 @@ ht.close(); } - @Test + @Ignore @Test public void testBulkDeleteColumnVersionBasedOnTS() throws Throwable { byte[] tableName = Bytes.toBytes("testBulkDeleteColumnVersionBasedOnTS"); HTable ht = createTable(tableName); @@ -338,7 +339,7 @@ ht.close(); } - @Test + @Ignore @Test public void testBulkDeleteWithNumberOfVersions() throws Throwable { byte[] tableName = Bytes.toBytes("testBulkDeleteWithNumberOfVersions"); HTable ht = createTable(tableName); @@ -379,10 +380,10 @@ long noOfDeletedRows = 0L; long noOfVersionsDeleted = 0L; - Batch.Call callable = + Batch.Call callable = new Batch.Call() { ServerRpcController controller = new ServerRpcController(); - BlockingRpcCallback rpcCallback = + BlockingRpcCallback rpcCallback = new BlockingRpcCallback(); public BulkDeleteResponse call(BulkDeleteService service) throws IOException { Index: hbase-examples/src/test/java/org/apache/hadoop/hbase/coprocessor/example/TestRowCountEndpoint.java =================================================================== --- hbase-examples/src/test/java/org/apache/hadoop/hbase/coprocessor/example/TestRowCountEndpoint.java (revision 1452424) +++ hbase-examples/src/test/java/org/apache/hadoop/hbase/coprocessor/example/TestRowCountEndpoint.java (working copy) @@ -32,6 +32,7 @@ import org.junit.AfterClass; import org.junit.BeforeClass; import org.junit.Test; +import org.junit.Ignore; import org.junit.experimental.categories.Category; import java.io.IOException; @@ -69,7 +70,7 @@ TEST_UTIL.shutdownMiniCluster(); } - @Test + @Ignore @Test public void testEndpoint() throws Throwable { HTable table = new HTable(CONF, TEST_TABLE); Index: hbase-examples/src/test/java/org/apache/hadoop/hbase/coprocessor/example/TestZooKeeperScanPolicyObserver.java =================================================================== --- hbase-examples/src/test/java/org/apache/hadoop/hbase/coprocessor/example/TestZooKeeperScanPolicyObserver.java (revision 1452424) +++ hbase-examples/src/test/java/org/apache/hadoop/hbase/coprocessor/example/TestZooKeeperScanPolicyObserver.java (working copy) @@ -41,6 +41,7 @@ import org.junit.AfterClass; import org.junit.BeforeClass; import org.junit.Test; +import org.junit.Ignore; import org.junit.experimental.categories.Category; @Category(MediumTests.class) @@ -66,7 +67,7 @@ TEST_UTIL.shutdownMiniCluster(); } - @Test + @Ignore @Test public void testScanPolicyObserver() throws Exception { byte[] tableName = Bytes.toBytes("testScanPolicyObserver"); HTableDescriptor desc = new HTableDescriptor(tableName);