Index: src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java =================================================================== --- src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java (revision 1593477) +++ src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java (working copy) @@ -426,6 +426,11 @@ this.peerClusterZnode, this.repLogReader.getPosition(), queueRecovered, currentWALisBeingWrittenTo); this.lastLoggedPosition = this.repLogReader.getPosition(); } + if (!gotIOE) { + // if there was nothing to ship and it's not an error + // set "ageOfLastShippedOp" to to indicate that we're current + this.metrics.setAgeOfLastShippedOp(System.currentTimeMillis()); + } if (sleepForRetries("Nothing to replicate", sleepMultiplier)) { sleepMultiplier++; }