Index: hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java =================================================================== --- hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java (revision 1380256) +++ hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java (working copy) @@ -2468,12 +2468,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; }