From df725cd87fc04cd36fb22f3dbea6557e7fcdfa9e Mon Sep 17 00:00:00 2001 From: Chris Cranford Date: Thu, 5 Sep 2024 07:35:09 -0400 Subject: [PATCH] DBZ-8177 Don't apply flush wait for nodes that are not connected --- .../logminer/logwriter/RacCommitLogWriterFlushStrategy.java | 3 --- 1 file changed, 3 deletions(-) diff --git a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/logwriter/RacCommitLogWriterFlushStrategy.java b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/logwriter/RacCommitLogWriterFlushStrategy.java index b5e677675..125c17100 100644 --- a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/logwriter/RacCommitLogWriterFlushStrategy.java +++ b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/logwriter/RacCommitLogWriterFlushStrategy.java @@ -112,9 +112,6 @@ public void flush(Scn currentScn) throws InterruptedException { allNodesFlushed = false; } } - else { - allNodesFlushed = false; - } } if (!allNodesFlushed) {