Details
-
Bug
-
Status: Closed
-
Minor
-
Resolution: Fixed
-
0.94.1
-
None
-
Reviewed
Description
From code below we can see AgeOfLastShippedOp is not set correctly
ReplicationSource.java
// entriesArray init public void init(){ this.entriesArray = new HLog.Entry[this.replicationQueueNbCapacity]; for (int i = 0; i < this.replicationQueueNbCapacity; i++) { this.entriesArray[i] = new HLog.Entry(); } } //set the metrics value should not get the array length protected void shipEdits() { ... this.metrics.setAgeOfLastShippedOp( this.entriesArray[this.entriesArray.length-1].getKey().getWriteTime()); ... }