diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java index a91fc490fdd..0169315d052 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java @@ -2395,6 +2395,8 @@ public class HRegion implements HeapSize { // , Writable{ // Lock row Integer lid = getLock(lockId, get.getRow(), true); + // wait for all previous transactions to complete (with lock held) + mvcc.completeMemstoreInsert(mvcc.beginMemstoreInsert()); List result = null; try { result = get(get, false);