DBZ-2994 Use null default rather than Scn.ZERO
This commit is contained in:
parent
da02ca2a23
commit
f91a01fb86
@ -10,6 +10,7 @@
|
|||||||
import java.sql.Timestamp;
|
import java.sql.Timestamp;
|
||||||
import java.time.Duration;
|
import java.time.Duration;
|
||||||
import java.time.Instant;
|
import java.time.Instant;
|
||||||
|
import java.util.Objects;
|
||||||
|
|
||||||
import org.slf4j.Logger;
|
import org.slf4j.Logger;
|
||||||
import org.slf4j.LoggerFactory;
|
import org.slf4j.LoggerFactory;
|
||||||
@ -54,8 +55,8 @@ class LogMinerQueryResultProcessor {
|
|||||||
private final OracleConnectorConfig connectorConfig;
|
private final OracleConnectorConfig connectorConfig;
|
||||||
private final Clock clock;
|
private final Clock clock;
|
||||||
private final Logger LOGGER = LoggerFactory.getLogger(LogMinerQueryResultProcessor.class);
|
private final Logger LOGGER = LoggerFactory.getLogger(LogMinerQueryResultProcessor.class);
|
||||||
private Scn currentOffsetScn = Scn.ZERO;
|
private Scn currentOffsetScn;
|
||||||
private Scn currentOffsetCommitScn = Scn.ZERO;
|
private Scn currentOffsetCommitScn;
|
||||||
private long stuckScnCounter = 0;
|
private long stuckScnCounter = 0;
|
||||||
private HistoryRecorder historyRecorder;
|
private HistoryRecorder historyRecorder;
|
||||||
|
|
||||||
@ -263,7 +264,7 @@ private void warnStuckScn() {
|
|||||||
if (offsetContext != null && offsetContext.getCommitScn() != null) {
|
if (offsetContext != null && offsetContext.getCommitScn() != null) {
|
||||||
final Scn scn = offsetContext.getScn();
|
final Scn scn = offsetContext.getScn();
|
||||||
final Scn commitScn = offsetContext.getCommitScn();
|
final Scn commitScn = offsetContext.getCommitScn();
|
||||||
if (currentOffsetScn.equals(scn) && !currentOffsetCommitScn.equals(commitScn)) {
|
if (Objects.equals(currentOffsetScn, scn) && !Objects.equals(currentOffsetCommitScn, commitScn)) {
|
||||||
stuckScnCounter++;
|
stuckScnCounter++;
|
||||||
// logWarn only once
|
// logWarn only once
|
||||||
if (stuckScnCounter == 25) {
|
if (stuckScnCounter == 25) {
|
||||||
|
Loading…
Reference in New Issue
Block a user