diff --git a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/processor/TransactionCommitConsumer.java b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/processor/TransactionCommitConsumer.java index 7cb22e8a4..109ee02dd 100644 --- a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/processor/TransactionCommitConsumer.java +++ b/debezium-connector-oracle/src/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; }