gistfile1.diff

diff --git a/src/main/java/org/apache/hadoop/hbase/regionserver/MemStore.java b/src/main/java/org/apache/hadoop/hbase/regionserver/MemStore.java
index b7409b0..fa773b8 100644
--- a/src/main/java/org/apache/hadoop/hbase/regionserver/MemStore.java
+++ b/src/main/java/org/apache/hadoop/hbase/regionserver/MemStore.java
@@ -466,9 +466,13 @@ public class MemStore implements HeapSize {
     // Add the KeyValue to the MemStore
     long addedSize = add(kv);
 
+    KeyValue firstKv = KeyValue.createFirstOnRow(
+        kv.getBuffer(), kv.getKeyOffset(), kv.getKeyLength(),
+        kv.getBuffer(), kv.getFamilyOffset(), kv.getFamilyLength(),
+        kv.getBuffer(), kv.getQualifierOffset(), kv.getQualifierLength());
     // Iterate the KeyValues after the one just inserted, cleaning up any
     // other KeyValues with the same row/family/qualifier
-    SortedSet<KeyValue> ss = kvset.tailSet(kv);
+    SortedSet<KeyValue> ss = kvset.tailSet(firstKv);
     Iterator<KeyValue> it = ss.iterator();
     while ( it.hasNext() ) {
       KeyValue cur = it.next();