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 1447581) +++ hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java (working copy) @@ -329,7 +329,12 @@ currentNbEntries = 0; currentSize = 0; try { + Path lastPath = this.currentPath; if (readAllEntriesToReplicateOrNextFile(currentWALisBeingWrittenTo)) { + if(currentWALisBeingWrittenTo == false){ + this.manager.logPositionAndCleanOldLogs(lastPath,this.peerClusterZnode, + this.repLogReader.getPosition(), queueRecovered, currentWALisBeingWrittenTo); + } continue; } } catch (IOException ioe) {