DBZ-7345 Use equality check instead

couchbase · Jan 17, 2024 · 632b4f8 · 632b4f8
1 parent adaaebe
commit 632b4f8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/LogMinerHelper.java b/...-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/LogMinerHelper.java
@@ -218,7 +218,7 @@ public static List<LogFile> deduplicateLogFiles(Collection<LogFile> archiveLogs,
         // Remove the archive log which has the same sequence number and redo thread number.
         for (LogFile redoLog : redoLogs) {
             archiveLogs.removeIf(f -> {
-                if (f.getSequence().equals(redoLog.getSequence()) && f.getThread() == redoLog.getThread()) {
+                if (f.equals(redoLog)) {
                     LOGGER.debug("Removing redo thread {} archive log {} with duplicate sequence {} to {}",
                             f.getThread(), f.getFileName(), f.getSequence(), redoLog.getFileName());
                     return true;