Index: hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java =================================================================== --- hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java (revision 1381265) +++ hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java (working copy) @@ -430,7 +430,16 @@ currentNbEntries >= this.replicationQueueNbCapacity) { break; } - entry = this.reader.next(entriesArray[currentNbEntries]); + try { + entry = this.reader.next(entriesArray[currentNbEntries]); + } catch (IOException ie) { + //We don't want to lose the work we have done so far and hence we + //'break' (and ultimately return) out of the method on getting an + //exception. The same exception will be thrown on the next call + //to this method + LOG.debug("Ignoring the exception " + ie); + break; + } } LOG.debug("currentNbOperations:" + currentNbOperations + " and seenEntries:" + seenEntries +