Skip to content

Commit 933e754

Browse files
committed
debezium/dbz#1560 Update lower mining boundary on each pass
Signed-off-by: Chris Cranford <chris@hibernate.org>
1 parent 02ae175 commit 933e754

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/buffered/BufferedLogMinerStreamingChangeEventSource.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -173,8 +173,8 @@ else if (!restartRequired) {
173173
// beginning, middle, or end of the log. So by updating this value if and only if
174174
// the log changes, allows for maximum session reuse.
175175
sessionStartScnChanged = true;
176-
sessionStartScn = result.miningSessionStartScn;
177176
}
177+
sessionStartScn = result.miningSessionStartScn;
178178
}
179179

180180
readScn = result.readStartScn();

0 commit comments

Comments
 (0)