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 cc89b84..5418c0e 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 @@ -5275,6 +5275,9 @@ public class HRegion implements HeapSize, PropagatingConfigurationObserver, Regi ByteStringer.wrap(this.getRegionInfo().getEncodedNameAsBytes()), storeFiles, seqId); WALUtil.writeBulkLoadMarkerAndSync(wal, this.htableDescriptor, getRegionInfo(), loadDescriptor, sequenceId); + MultiVersionConsistencyControl.WriteEntry w = mvcc.beginMemstoreInsert(); + w.setWriteNumber(sequenceId.get()); + mvcc.waitForPreviousTransactionsComplete(w); } catch (IOException ioe) { if (this.rsServices != null) { // Have to abort region server because some hfiles has been loaded but we can't write