alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-8054 Fix oldest transaction comparison logic

Browse Source
This commit is contained in:
Jeremy Ford 2024-07-27 08:16:17 -05:00 committed by Chris Cranford
parent 1315842f1f
commit bebf53a143
2 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/processor/AbstractLogMinerEventProcessor.java
View File

@ -1676,6 +1676,14 @@ protected int compareStartScn(T first, T second) {
return first.getStartScn().compareTo(second.getStartScn());
}
protected int oldestTransactionComparison(T first, T second) {
int comparison = compareStartScn(first, second);
if (comparison == 0) {
comparison = first.getChangeTime().compareTo(second.getChangeTime());
}
return comparison;
}
/**
* Wrapper for all counter variables
*

2
debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/processor/AbstractTransactionCachingLogMinerEventProcessor.java
View File

@ -107,7 +107,7 @@ protected Scn getTransactionCacheMinimumScn() {
protected Optional<T> getOldestTransactionInCache() {
return getTransactionCache().streamAndReturn(stream -> stream.map(LogMinerCache.Entry::getValue)
.min(this::compareStartScn));
.min(this::oldestTransactionComparison));
}
@Override