From f91a01fb8666e2b5e465a9d6fee39e548afbf944 Mon Sep 17 00:00:00 2001 From: Chris Cranford Date: Wed, 17 Mar 2021 05:26:39 -0400 Subject: [PATCH] DBZ-2994 Use null default rather than Scn.ZERO --- .../oracle/logminer/LogMinerQueryResultProcessor.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/LogMinerQueryResultProcessor.java b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/LogMinerQueryResultProcessor.java index 294636003..e0777ebe5 100644 --- a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/LogMinerQueryResultProcessor.java +++ b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/LogMinerQueryResultProcessor.java @@ -10,6 +10,7 @@ import java.sql.Timestamp; import java.time.Duration; import java.time.Instant; +import java.util.Objects; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -54,8 +55,8 @@ class LogMinerQueryResultProcessor { private final OracleConnectorConfig connectorConfig; private final Clock clock; private final Logger LOGGER = LoggerFactory.getLogger(LogMinerQueryResultProcessor.class); - private Scn currentOffsetScn = Scn.ZERO; - private Scn currentOffsetCommitScn = Scn.ZERO; + private Scn currentOffsetScn; + private Scn currentOffsetCommitScn; private long stuckScnCounter = 0; private HistoryRecorder historyRecorder; @@ -263,7 +264,7 @@ private void warnStuckScn() { if (offsetContext != null && offsetContext.getCommitScn() != null) { final Scn scn = offsetContext.getScn(); final Scn commitScn = offsetContext.getCommitScn(); - if (currentOffsetScn.equals(scn) && !currentOffsetCommitScn.equals(commitScn)) { + if (Objects.equals(currentOffsetScn, scn) && !Objects.equals(currentOffsetCommitScn, commitScn)) { stuckScnCounter++; // logWarn only once if (stuckScnCounter == 25) {