Index: src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java =================================================================== --- src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java (revision 1378969) +++ src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java (working copy) @@ -2470,12 +2470,13 @@ // Using default cluster id, as this can only happen in the // originating cluster. A slave cluster receives the result as a Put // or Delete + Pair[] batchOp = new Pair[1]; if (isPut) { - internalPut(((Put) w), HConstants.DEFAULT_CLUSTER_ID, writeToWAL); + batchOp[0] = new Pair (((Put)w), lid); + doMiniBatchMutation(new BatchOperationInProgress>(batchOp)); } else { - Delete d = (Delete)w; - prepareDelete(d); - internalDelete(d, HConstants.DEFAULT_CLUSTER_ID, writeToWAL); + batchOp[0] = new Pair (((Delete)w), lid); + doMiniBatchMutation(new BatchOperationInProgress>(batchOp)); } return true; }