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

DBZ-8119 Seed endScn as Scn.NULL

Browse Source
This commit is contained in:
Chris Cranford 2024-08-02 10:24:03 -04:00 committed by Jiri Pechanec
parent 9acc2f87c0
commit ea908249a1
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/LogMinerStreamingChangeEventSource.java
View File

@ -83,7 +83,7 @@ public class LogMinerStreamingChangeEventSource implements StreamingChangeEventS
private final boolean continuousMining;
private Scn startScn; // startScn is the **exclusive** lower bound for mining
private Scn endScn;
private Scn endScn = Scn.NULL;
private Scn snapshotScn;
private List<LogFile> currentLogFiles;
private List<BigInteger> currentRedoLogSequences;
@ -733,7 +733,7 @@ private Scn calculateUpperBounds(Scn startScn, Scn prevEndScn) throws SQLExcepti
result = upperBoundsScn;
}
else {
if (prevEndScn != null && batchUpperBoundsScn.compareTo(prevEndScn) <= 0) {
if (!prevEndScn.isNull() && batchUpperBoundsScn.compareTo(prevEndScn) <= 0) {
// Batch size is too small, make a large leap and use current SCN
LOGGER.debug("Batch size upper bounds {} too small, using maximum read position {} instead.", batchUpperBoundsScn, upperBoundsScn);
result = upperBoundsScn;
@ -745,7 +745,7 @@ private Scn calculateUpperBounds(Scn startScn, Scn prevEndScn) throws SQLExcepti
LOGGER.debug("Batch upper bounds {} is before start SCN {}, fallback to maximum read position {}.", batchUpperBoundsScn, startScn, upperBoundsScn);
result = upperBoundsScn;
}
else if (prevEndScn != null) {
else if (!prevEndScn.isNull()) {
final Scn deltaScn = upperBoundsScn.subtract(prevEndScn);
if (deltaScn.compareTo(Scn.valueOf(connectorConfig.getLogMiningScnGapDetectionGapSizeMin())) > 0) {
Optional<Instant> prevEndScnTimestamp = jdbcConnection.getScnToTimestamp(prevEndScn);