diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/mapreduce/IntegrationTestBulkLoad.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/mapreduce/IntegrationTestBulkLoad.java index dd4415b..68631d3 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/mapreduce/IntegrationTestBulkLoad.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/mapreduce/IntegrationTestBulkLoad.java @@ -183,6 +183,8 @@ public class IntegrationTestBulkLoad extends IntegrationTestBase { // Use the identity reducer // So nothing to do here. + job.setPartitionerClass(HRegionPartitioner.class); + // Set this jar. job.setJarByClass(getClass()); diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestHRegionServerBulkLoad.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestHRegionServerBulkLoad.java index a3218c5..d4a3b54 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestHRegionServerBulkLoad.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestHRegionServerBulkLoad.java @@ -255,7 +255,11 @@ public class TestHRegionServerBulkLoad { htd.addFamily(new HColumnDescriptor(family(i))); } - UTIL.getHBaseAdmin().createTable(htd); + byte[][] families = new byte[10][]; + for (int i = 0; i < 10; i++) { + families[i] = Bytes.toBytes(family(i)); + } + UTIL.createTable(table, families, 1, Bytes.toBytes("aa"), Bytes.toBytes("cc"), 32); } catch (TableExistsException tee) { LOG.info("Table " + table + " already exists"); }