### Eclipse Workspace Patch 1.0 #P hbase-0.19-branch Index: src/java/org/apache/hadoop/hbase/mapred/TableMapReduceUtil.java =================================================================== --- src/java/org/apache/hadoop/hbase/mapred/TableMapReduceUtil.java (revision 764658) +++ src/java/org/apache/hadoop/hbase/mapred/TableMapReduceUtil.java (working copy) @@ -93,13 +93,15 @@ job.set(TableOutputFormat.OUTPUT_TABLE, table); job.setOutputKeyClass(ImmutableBytesWritable.class); job.setOutputValueClass(BatchUpdate.class); - if (partitioner != null) { + if (partitioner == HRegionPartitioner.class) { job.setPartitionerClass(HRegionPartitioner.class); HTable outputTable = new HTable(new HBaseConfiguration(job), table); int regions = outputTable.getRegionsInfo().size(); if (job.getNumReduceTasks() > regions){ - job.setNumReduceTasks(outputTable.getRegionsInfo().size()); + job.setNumReduceTasks(outputTable.getRegionsInfo().size()); } + } else { + job.setPartitionerClass(partitioner); } } } \ No newline at end of file