DBZ-4384 Correctly skip emitting events when LOB_ERASE is detected

debezium · Dec 1, 2021 · 54cb7be · 54cb7be
1 parent 71eb089
commit 54cb7be
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/.../main/java/io/debezium/connector/oracle/logminer/processor/TransactionCommitConsumer.java b/.../main/java/io/debezium/connector/oracle/logminer/processor/TransactionCommitConsumer.java
@@ -197,6 +197,11 @@ else if (EventType.LOB_ERASE == event.getEventType()) {
             // nothing is done with the event, its just consumed and treated as merged.
             LOGGER.warn("\tLOB_ERASE for table '{}' column '{}' is not supported.",
                     lastSelectLobLocatorEvent.getTableId(), lastSelectLobLocatorEvent.getColumnName());
+            if (lastEvent != null && EventType.SELECT_LOB_LOCATOR == lastEvent.getEventType()) {
+                LOGGER.trace("\tSkipped LOB_ERASE, discarding it and the prior SELECT_LOB_LOCATOR");
+                lastEvent = null;
+                return true;
+            }
             LOGGER.trace("\tSkipped LOB_ERASE, treated as merged.");
             return true;
         }