From 5aeb5899329c2ff62c56ae8c522a121fac5ec95b Mon Sep 17 00:00:00 2001 From: Gunnar Morling Date: Tue, 11 Dec 2018 12:00:53 +0100 Subject: [PATCH] DBZ-848 Adding Tautvydas Januskevicius to COPYRIGHT.txt --- COPYRIGHT.txt | 1 + .../src/main/java/io/debezium/connector/mongodb/Replicator.java | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/COPYRIGHT.txt b/COPYRIGHT.txt index c9de8927c..aed7c8f67 100644 --- a/COPYRIGHT.txt +++ b/COPYRIGHT.txt @@ -61,6 +61,7 @@ Sherafudheen PM Stanley Shyiko Stephen Powis Steven Siahetiong +Tautvydas Januskevicius Tom Bentley WenZe Hu Willie Cheong diff --git a/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/Replicator.java b/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/Replicator.java index 8336dd4b4..765885be0 100644 --- a/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/Replicator.java +++ b/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/Replicator.java @@ -451,8 +451,8 @@ protected boolean handleOplogEvent(ServerAddress primaryAddress, Document event) } ServerAddress serverAddress = address.get(); + //primary switch will be handled automatically by MongoDB driver if (serverAddress != null && !serverAddress.equals(primaryAddress)) { - //primary switch will be handled automatically by mongo driver. logger.info("Found new primary event in oplog, so stopping use of {} to continue with new primary {}", primaryAddress, serverAddress); } else {