DBZ-8054 Fix test failures
This commit is contained in:
parent
bebf53a143
commit
c056d7657e
@ -367,10 +367,9 @@ protected Scn calculateNewStartScn(Scn endScn, Scn maxCommittedScn) throws Inter
|
||||
endScn = getLastProcessedScn();
|
||||
}
|
||||
|
||||
// update offsets
|
||||
offsetContext.setScn(endScn);
|
||||
offsetContext.setScn(minCacheScn.isNull() ? endScn : minCacheScn.subtract(Scn.valueOf(1)));
|
||||
metrics.setOldestScnDetails(minCacheScn, minCacheScnChangeTime);
|
||||
metrics.setOffsetScn(endScn);
|
||||
metrics.setOffsetScn(offsetContext.getScn());
|
||||
|
||||
// optionally dispatch a heartbeat event
|
||||
dispatcher.dispatchHeartbeatEvent(partition, offsetContext);
|
||||
|
Loading…
Reference in New Issue
Block a user