Index: src/java/org/apache/hadoop/hbase/mapreduce/KeyValueSortReducer.java =================================================================== --- src/java/org/apache/hadoop/hbase/mapreduce/KeyValueSortReducer.java (revision 897523) +++ src/java/org/apache/hadoop/hbase/mapreduce/KeyValueSortReducer.java (working copy) @@ -38,7 +38,7 @@ throws java.io.IOException, InterruptedException { TreeSet map = new TreeSet(KeyValue.COMPARATOR); for (KeyValue kv: kvs) { - map.add(kv); + map.add(kv.clone()); } context.setStatus("Read " + map.getClass()); int index = 0;