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) {