Hello,
I trying to influence replication latency with tserver.walog.max.age. But
noticing no difference when setting the value low. Looking in the code of
org.apache.accumulo.tserver.log.TabletServerLogger:
protected void closeForReplication(Collection<CommitSession> sessions) {
// TODO We can close the WAL here for replication purposes
}
This to do is called by :
testLockAndRun(logSetLock, new TestCallWithWriteLock() {
@Override
boolean test() {
return (logSizeEstimate.get() > maxSize) ||
((System.currentTimeMillis() - createTime) > maxAge);
}
@Override
void withWriteLock() throws IOException {
close();
closeForReplication(sessions);
}
});
return seq;
}
I am still trying to understand what is happening here, but could this TODO
be the reason replication status records are not being updated with
'closed: true' sooner ?
Thank you
Noe