Merge branch 'master' of http://git.navis.lan/scm/n4fra/debezium

AndreyIg · Mar 24, 2020 · 43ce5a6 · 43ce5a6
2 parents 89feb14 + ed0579e
commit 43ce5a6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...c/main/java/io/debezium/connector/oracle/logminer/LogMinerStreamingChangeEventSource.java b/...c/main/java/io/debezium/connector/oracle/logminer/LogMinerStreamingChangeEventSource.java
@@ -73,8 +73,8 @@ public LogMinerStreamingChangeEventSource(OracleConnectorConfig connectorConfig,
 
 //        this.dmlParser = new OracleDmlParser(true, connectorConfig.getDatabaseName(), connectorConfig.getSchemaName(),
 //                converters);
-        this.dmlParser = new SimpleDmlParser(connectorConfig.getDatabaseName(), connectorConfig.getSchemaName(), converters);
         this.catalogName = (connectorConfig.getPdbName() != null) ? connectorConfig.getPdbName() : connectorConfig.getDatabaseName();
+        this.dmlParser = new SimpleDmlParser(catalogName, connectorConfig.getSchemaName(), converters);
         this.transactionalBufferMetrics = new TransactionalBufferMetrics(taskContext);
         this.transactionalBufferMetrics.register(LOGGER);
         transactionalBuffer = new TransactionalBuffer(connectorConfig.getLogicalName(), errorHandler, transactionalBufferMetrics);