diff --git a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/processor/infinispan/InfinispanLogMinerEventProcessor.java b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/processor/infinispan/InfinispanLogMinerEventProcessor.java index 5b4d58ced..6e914d60c 100644 --- a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/processor/infinispan/InfinispanLogMinerEventProcessor.java +++ b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/processor/infinispan/InfinispanLogMinerEventProcessor.java @@ -255,7 +255,6 @@ else if (getConfig().getLogMiningUsernameExcludes().contains(transaction.getUser skipExcludedUserName = true; } - final Scn smallestScn = transactionCache.getMinimumScn(); metrics.setOldestScn(smallestScn.isNull() ? Scn.valueOf(-1) : smallestScn); @@ -299,7 +298,7 @@ else if (getConfig().getLogMiningUsernameExcludes().contains(transaction.getUser // after reconciliation all events should be DML // todo: do we want to move dml entry up and just let it be null to avoid cast? final DmlEvent dmlEvent = (DmlEvent) event; - if(!skipExcludedUserName) { + if (!skipExcludedUserName) { dispatcher.dispatchDataChangeEvent(event.getTableId(), new LogMinerChangeRecordEmitter( partition, diff --git a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/processor/memory/MemoryLogMinerEventProcessor.java b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/processor/memory/MemoryLogMinerEventProcessor.java index b8511ecef..40b209ac3 100644 --- a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/processor/memory/MemoryLogMinerEventProcessor.java +++ b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/processor/memory/MemoryLogMinerEventProcessor.java @@ -269,7 +269,7 @@ else if (getConfig().getLogMiningUsernameExcludes().contains(transaction.getUser // after reconciliation all events should be DML final DmlEvent dmlEvent = (DmlEvent) event; - if(!skipExcludedUserName) { + if (!skipExcludedUserName) { dispatcher.dispatchDataChangeEvent(event.getTableId(), new LogMinerChangeRecordEmitter( partition, diff --git a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleConnectorIT.java b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleConnectorIT.java index a71ff4028..9fc1d8565 100644 --- a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleConnectorIT.java +++ b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleConnectorIT.java @@ -2297,7 +2297,7 @@ private T getStreamingMetric(String metricName) throws JMException { final ObjectName objectName = getStreamingMetricsObjectName(TestHelper.CONNECTOR_NAME, TestHelper.SERVER_NAME); return (T) mbeanServer.getAttribute(objectName, metricName); } - + private String generateAlphaNumericStringColumn(int size) { final String alphaNumericString = "ABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789abcdefghijklmnopqrstuvwxyz"; final StringBuilder sb = new StringBuilder(size);