Index: src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java =================================================================== --- src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java (revision 1378459) +++ src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java (working copy) @@ -424,7 +424,11 @@ currentNbEntries >= this.replicationQueueNbCapacity) { break; } - entry = this.reader.next(entriesArray[currentNbEntries]); + try { + entry = this.reader.next(entriesArray[currentNbEntries]); + } catch (IOException ie) { + break; + } } LOG.debug("currentNbOperations:" + currentNbOperations + " and seenEntries:" + seenEntries +