alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-3978 Fix formatting

Browse Source
This commit is contained in:
Chris Cranford 2021-09-29 14:50:46 -04:00
parent 33def4cb48
commit 6482733915
3 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/processor/infinispan/InfinispanLogMinerEventProcessor.java
View File

@ -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,

2
debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/processor/memory/MemoryLogMinerEventProcessor.java
View File

@ -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,

2
debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleConnectorIT.java
View File

@ -2297,7 +2297,7 @@ private <T> 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);