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 1586508) +++ hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java (working copy) @@ -3381,6 +3381,13 @@ return false; } + + // If we're going to assign a sequence id that's out of band from the memstores, + // at least request a flush first so that the chances of losing data are closer to nil. + if (assignSeqId) { + requestFlush(); + } + for (Pair p : familyPaths) { byte[] familyName = p.getFirst(); String path = p.getSecond();