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 1374140) +++ hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java (working copy) @@ -621,7 +621,7 @@ this.totalReplicatedEdits += currentNbEntries; this.metrics.shipBatch(this.currentNbOperations); this.metrics.setAgeOfLastShippedOp( - this.entriesArray[this.entriesArray.length-1].getKey().getWriteTime()); + this.entriesArray[currentNbEntries-1].getKey().getWriteTime()); LOG.debug("Replicated in total: " + this.totalReplicatedEdits); break;