Merge branch 'master' of http://git.navis.lan/scm/n4fra/debezium

AndreyIg · Feb 26, 2020 · 926c648 · 926c648
2 parents 92140a3 + 829206c
commit 926c648
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...ector-oracle/src/main/java/io/debezium/connector/oracle/logminer/TransactionalBuffer.java b/...ector-oracle/src/main/java/io/debezium/connector/oracle/logminer/TransactionalBuffer.java
@@ -238,7 +238,7 @@ private BigDecimal calculateSmallestScn() {
     }
 
     private void calculateLargestFirstScn() {
-        largestFirstScn = transactions.isEmpty() ? null : transactions.values()
+        largestFirstScn = transactions.isEmpty() ? BigDecimal.ZERO : transactions.values()
                 .stream()
                 .map(transaction -> transaction.firstScn)
                 .max(BigDecimal::compareTo)
@@ -247,7 +247,7 @@ private void calculateLargestFirstScn() {
     }
 
     private void calculateLargestLastScn() {
-        largestLastScn = transactions.isEmpty() ? null : transactions.values()
+        largestLastScn = transactions.isEmpty() ? BigDecimal.ZERO : transactions.values()
                 .stream()
                 .map(transaction -> transaction.lastScn)
                 .max(BigDecimal::compareTo)