zhuxt2015 commented on PR #3593:
URL: https://github.com/apache/flink-cdc/pull/3593#issuecomment-2365169738
> Thanks for @zhuxt2015's contribution! Would you mind adding a test case to
verify this change?
我参考其他测试用例写的oracle分区表的测试用例，但是运行会报错，一直没找到解决办法，您能帮忙看一下吗？
I refer to the test case of the oracle partition table written by other test
cases, but the error will be reported when running, and I have not found a
solution, can you help me take a look?
```
159109 [Source: test_partition_table[1] -> DropUpdateBefore[2] ->
ConstraintEnforcer[3] -> Sink: test_partition_sink[3] (1/4)#1] WARN
org.apache.flink.runtime.taskmanager.Task - Source: test_partition_table[1] ->
DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: test_partition_sink[3]
(1/4)#1 (7d49ef3353baa61a7d77363cc0d5d501_cbc357ccb763df2852fee8c4fc7d55f2_0_1)
switched from RUNNING to FAILED with failure cause:
org.apache.flink.util.FlinkRuntimeException: java.lang.RuntimeException:
Failed to resolve Oracle database version
at
org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceReader.discoverTableSchemasForStreamSplit(IncrementalSourceReader.java:348)
~[classes/:?]
at
org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceReader.addSplits(IncrementalSourceReader.java:308)
~[classes/:?]
at
org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceReader.addSplits(IncrementalSourceReader.java:248)
~[classes/:?]
at
org.apache.flink.streaming.api.operators.SourceOperator.handleAddSplitsEvent(SourceOperator.java:590)
~[flink-streaming-java-1.18.1.jar:1.18.1]
at
org.apache.flink.streaming.api.operators.SourceOperator.handleOperatorEvent(SourceOperator.java:567)
~[flink-streaming-java-1.18.1.jar:1.18.1]
at
org.apache.flink.streaming.runtime.tasks.OperatorEventDispatcherImpl.dispatchEventToHandlers(OperatorEventDispatcherImpl.java:72)
~[flink-streaming-java-1.18.1.jar:1.18.1]
at
org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.dispatchOperatorEvent(RegularOperatorChain.java:80)
~[flink-streaming-java-1.18.1.jar:1.18.1]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$dispatchOperatorEvent$21(StreamTask.java:1492)
~[flink-streaming-java-1.18.1.jar:1.18.1]
at
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:50)
~[flink-streaming-java-1.18.1.jar:1.18.1]
at
org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:90)
~[flink-streaming-java-1.18.1.jar:1.18.1]
at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMail(MailboxProcessor.java:398)
~[flink-streaming-java-1.18.1.jar:1.18.1]
at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMailsWhenDefaultActionUnavailable(MailboxProcessor.java:367)
~[flink-streaming-java-1.18.1.jar:1.18.1]
at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMail(MailboxProcessor.java:352)
~[flink-streaming-java-1.18.1.jar:1.18.1]
at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:229)
~[flink-streaming-java-1.18.1.jar:1.18.1]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:858)
~[flink-streaming-java-1.18.1.jar:1.18.1]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:807)
~[flink-streaming-java-1.18.1.jar:1.18.1]
at
org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:953)
~[flink-runtime-1.18.1.jar:1.18.1]
at
org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:932)
[flink-runtime-1.18.1.jar:1.18.1]
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:746)
[flink-runtime-1.18.1.jar:1.18.1]
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:562)
[flink-runtime-1.18.1.jar:1.18.1]
at java.lang.Thread.run(Thread.java:750) [?:1.8.0_401]
Caused by: java.lang.RuntimeException: Failed to resolve Oracle database
version
at
io.debezium.connector.oracle.OracleConnection.resolveOracleDatabaseVersion(OracleConnection.java:177)
~[debezium-connector-oracle-1.9.8.Final.jar:1.9.8.Final]
at
io.debezium.connector.oracle.OracleConnection.<init>(OracleConnection.java:87)
~[debezium-connector-oracle-1.9.8.Final.jar:1.9.8.Final]
at
io.debezium.connector.oracle.OracleConnection.<init>(OracleConnection.java:82)
~[debezium-connector-oracle-1.9.8.Final.jar:1.9.8.Final]
at
org.apache.flink.cdc.connectors.oracle.source.utils.OracleConnectionUtils.createOracleConnection(OracleConnectionUtils.java:61)
~[classes/:?]
at
org.apache.flink.cdc.connectors.oracle.source.OracleDialect.openJdbcConnection(OracleDialect.java:86)
~[classes/:?]
at
org.apache.flink.cdc.connectors.oracle.source.OracleDialect.discoverDataCollections(OracleDialect.java:103)
~[classes/:?]
at
org.apache.flink.cdc.connectors.oracle.source.OracleDialect.discoverDataCollectionSchemas(OracleDialect.java:113)
~[classes/:?]
at
org.apache.flink.cdc.connectors.oracle.source.OracleDialect.discoverDataCollectionSchemas(OracleDialect.java:52)
~[classes/:?]
at
org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceReader.discoverTableSchemasForStreamSplit(IncrementalSourceReader.java:336)
~[classes/:?]
... 20 more
Caused by: java.sql.SQLRecoverableException: IO 错误: The Network Adapter
could not establish the connection
at oracle.jdbc.driver.T4CConnection.logon(T4CConnection.java:854)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at
oracle.jdbc.driver.PhysicalConnection.connect(PhysicalConnection.java:793)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at
oracle.jdbc.driver.T4CDriverExtension.getConnection(T4CDriverExtension.java:57)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.jdbc.driver.OracleDriver.connect(OracleDriver.java:747)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.jdbc.driver.OracleDriver.connect(OracleDriver.java:562)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at java.sql.DriverManager.getConnection(DriverManager.java:664)
~[?:1.8.0_401]
at java.sql.DriverManager.getConnection(DriverManager.java:208)
~[?:1.8.0_401]
at
io.debezium.jdbc.JdbcConnection.lambda$patternBasedFactory$0(JdbcConnection.java:192)
~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at
io.debezium.jdbc.JdbcConnection$ConnectionFactoryDecorator.connect(JdbcConnection.java:129)
~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:888)
~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:883)
~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:636)
~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:510)
~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at
io.debezium.connector.oracle.OracleConnection.resolveOracleDatabaseVersion(OracleConnection.java:147)
~[debezium-connector-oracle-1.9.8.Final.jar:1.9.8.Final]
at
io.debezium.connector.oracle.OracleConnection.<init>(OracleConnection.java:87)
~[debezium-connector-oracle-1.9.8.Final.jar:1.9.8.Final]
at
io.debezium.connector.oracle.OracleConnection.<init>(OracleConnection.java:82)
~[debezium-connector-oracle-1.9.8.Final.jar:1.9.8.Final]
at
org.apache.flink.cdc.connectors.oracle.source.utils.OracleConnectionUtils.createOracleConnection(OracleConnectionUtils.java:61)
~[classes/:?]
at
org.apache.flink.cdc.connectors.oracle.source.OracleDialect.openJdbcConnection(OracleDialect.java:86)
~[classes/:?]
at
org.apache.flink.cdc.connectors.oracle.source.OracleDialect.discoverDataCollections(OracleDialect.java:103)
~[classes/:?]
at
org.apache.flink.cdc.connectors.oracle.source.OracleDialect.discoverDataCollectionSchemas(OracleDialect.java:113)
~[classes/:?]
at
org.apache.flink.cdc.connectors.oracle.source.OracleDialect.discoverDataCollectionSchemas(OracleDialect.java:52)
~[classes/:?]
at
org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceReader.discoverTableSchemasForStreamSplit(IncrementalSourceReader.java:336)
~[classes/:?]
... 20 more
Caused by: oracle.net.ns.NetException: The Network Adapter could not
establish the connection
at oracle.net.nt.ConnStrategy.execute(ConnStrategy.java:571)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at
oracle.net.resolver.AddrResolution.resolveAndExecute(AddrResolution.java:548)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.net.ns.NSProtocol.establishConnection(NSProtocol.java:682)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.net.ns.NSProtocol.connect(NSProtocol.java:309)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.jdbc.driver.T4CConnection.connect(T4CConnection.java:1596)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.jdbc.driver.T4CConnection.logon(T4CConnection.java:588)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at
oracle.jdbc.driver.PhysicalConnection.connect(PhysicalConnection.java:793)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at
oracle.jdbc.driver.T4CDriverExtension.getConnection(T4CDriverExtension.java:57)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.jdbc.driver.OracleDriver.connect(OracleDriver.java:747)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.jdbc.driver.OracleDriver.connect(OracleDriver.java:562)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at java.sql.DriverManager.getConnection(DriverManager.java:664)
~[?:1.8.0_401]
at java.sql.DriverManager.getConnection(DriverManager.java:208)
~[?:1.8.0_401]
at
io.debezium.jdbc.JdbcConnection.lambda$patternBasedFactory$0(JdbcConnection.java:192)
~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at
io.debezium.jdbc.JdbcConnection$ConnectionFactoryDecorator.connect(JdbcConnection.java:129)
~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:888)
~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:883)
~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:636)
~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:510)
~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at
io.debezium.connector.oracle.OracleConnection.resolveOracleDatabaseVersion(OracleConnection.java:147)
~[debezium-connector-oracle-1.9.8.Final.jar:1.9.8.Final]
at
io.debezium.connector.oracle.OracleConnection.<init>(OracleConnection.java:87)
~[debezium-connector-oracle-1.9.8.Final.jar:1.9.8.Final]
at
io.debezium.connector.oracle.OracleConnection.<init>(OracleConnection.java:82)
~[debezium-connector-oracle-1.9.8.Final.jar:1.9.8.Final]
at
org.apache.flink.cdc.connectors.oracle.source.utils.OracleConnectionUtils.createOracleConnection(OracleConnectionUtils.java:61)
~[classes/:?]
at
org.apache.flink.cdc.connectors.oracle.source.OracleDialect.openJdbcConnection(OracleDialect.java:86)
~[classes/:?]
at
org.apache.flink.cdc.connectors.oracle.source.OracleDialect.discoverDataCollections(OracleDialect.java:103)
~[classes/:?]
at
org.apache.flink.cdc.connectors.oracle.source.OracleDialect.discoverDataCollectionSchemas(OracleDialect.java:113)
~[classes/:?]
at
org.apache.flink.cdc.connectors.oracle.source.OracleDialect.discoverDataCollectionSchemas(OracleDialect.java:52)
~[classes/:?]
at
org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceReader.discoverTableSchemasForStreamSplit(IncrementalSourceReader.java:336)
~[classes/:?]
... 20 more
Caused by: java.io.IOException: Connection refused, socket connect lapse 1
ms. /0:0:0:0:0:0:0:1 62469 0 1 true
at oracle.net.nt.TcpNTAdapter.connect(TcpNTAdapter.java:233)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.net.nt.ConnOption.connect(ConnOption.java:174)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.net.nt.ConnStrategy.execute(ConnStrategy.java:510)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at
oracle.net.resolver.AddrResolution.resolveAndExecute(AddrResolution.java:548)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.net.ns.NSProtocol.establishConnection(NSProtocol.java:682)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.net.ns.NSProtocol.connect(NSProtocol.java:309)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.jdbc.driver.T4CConnection.connect(T4CConnection.java:1596)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.jdbc.driver.T4CConnection.logon(T4CConnection.java:588)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at
oracle.jdbc.driver.PhysicalConnection.connect(PhysicalConnection.java:793)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at
oracle.jdbc.driver.T4CDriverExtension.getConnection(T4CDriverExtension.java:57)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.jdbc.driver.OracleDriver.connect(OracleDriver.java:747)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.jdbc.driver.OracleDriver.connect(OracleDriver.java:562)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at java.sql.DriverManager.getConnection(DriverManager.java:664)
~[?:1.8.0_401]
at java.sql.DriverManager.getConnection(DriverManager.java:208)
~[?:1.8.0_401]
at
io.debezium.jdbc.JdbcConnection.lambda$patternBasedFactory$0(JdbcConnection.java:192)
~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at
io.debezium.jdbc.JdbcConnection$ConnectionFactoryDecorator.connect(JdbcConnection.java:129)
~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:888)
~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:883)
~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:636)
~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:510)
~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at
io.debezium.connector.oracle.OracleConnection.resolveOracleDatabaseVersion(OracleConnection.java:147)
~[debezium-connector-oracle-1.9.8.Final.jar:1.9.8.Final]
at
io.debezium.connector.oracle.OracleConnection.<init>(OracleConnection.java:87)
~[debezium-connector-oracle-1.9.8.Final.jar:1.9.8.Final]
at
io.debezium.connector.oracle.OracleConnection.<init>(OracleConnection.java:82)
~[debezium-connector-oracle-1.9.8.Final.jar:1.9.8.Final]
at
org.apache.flink.cdc.connectors.oracle.source.utils.OracleConnectionUtils.createOracleConnection(OracleConnectionUtils.java:61)
~[classes/:?]
at
org.apache.flink.cdc.connectors.oracle.source.OracleDialect.openJdbcConnection(OracleDialect.java:86)
~[classes/:?]
at
org.apache.flink.cdc.connectors.oracle.source.OracleDialect.discoverDataCollections(OracleDialect.java:103)
~[classes/:?]
at
org.apache.flink.cdc.connectors.oracle.source.OracleDialect.discoverDataCollectionSchemas(OracleDialect.java:113)
~[classes/:?]
at
org.apache.flink.cdc.connectors.oracle.source.OracleDialect.discoverDataCollectionSchemas(OracleDialect.java:52)
~[classes/:?]
at
org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceReader.discoverTableSchemasForStreamSplit(IncrementalSourceReader.java:336)
~[classes/:?]
... 20 more
Caused by: java.net.ConnectException: Connection refused
at sun.nio.ch.Net.connect0(Native Method) ~[?:1.8.0_401]
at sun.nio.ch.Net.connect(Net.java:459) ~[?:1.8.0_401]
at sun.nio.ch.Net.connect(Net.java:451) ~[?:1.8.0_401]
at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:646)
~[?:1.8.0_401]
at java.nio.channels.SocketChannel.open(SocketChannel.java:189)
~[?:1.8.0_401]
at
oracle.net.nt.TimeoutSocketChannel.connect(TimeoutSocketChannel.java:99)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at
oracle.net.nt.TimeoutSocketChannel.<init>(TimeoutSocketChannel.java:77)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.net.nt.TcpNTAdapter.connect(TcpNTAdapter.java:192)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.net.nt.ConnOption.connect(ConnOption.java:174)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.net.nt.ConnStrategy.execute(ConnStrategy.java:510)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at
oracle.net.resolver.AddrResolution.resolveAndExecute(AddrResolution.java:548)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.net.ns.NSProtocol.establishConnection(NSProtocol.java:682)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.net.ns.NSProtocol.connect(NSProtocol.java:309)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.jdbc.driver.T4CConnection.connect(T4CConnection.java:1596)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.jdbc.driver.T4CConnection.logon(T4CConnection.java:588)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at
oracle.jdbc.driver.PhysicalConnection.connect(PhysicalConnection.java:793)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at
oracle.jdbc.driver.T4CDriverExtension.getConnection(T4CDriverExtension.java:57)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.jdbc.driver.OracleDriver.connect(OracleDriver.java:747)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.jdbc.driver.OracleDriver.connect(OracleDriver.java:562)
~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at java.sql.DriverManager.getConnection(DriverManager.java:664)
~[?:1.8.0_401]
at java.sql.DriverManager.getConnection(DriverManager.java:208)
~[?:1.8.0_401]
at
io.debezium.jdbc.JdbcConnection.lambda$patternBasedFactory$0(JdbcConnection.java:192)
~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at
io.debezium.jdbc.JdbcConnection$ConnectionFactoryDecorator.connect(JdbcConnection.java:129)
~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:888)
~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:883)
~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:636)
~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:510)
~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at
io.debezium.connector.oracle.OracleConnection.resolveOracleDatabaseVersion(OracleConnection.java:147)
~[debezium-connector-oracle-1.9.8.Final.jar:1.9.8.Final]
at
io.debezium.connector.oracle.OracleConnection.<init>(OracleConnection.java:87)
~[debezium-connector-oracle-1.9.8.Final.jar:1.9.8.Final]
at
io.debezium.connector.oracle.OracleConnection.<init>(OracleConnection.java:82)
~[debezium-connector-oracle-1.9.8.Final.jar:1.9.8.Final]
at
org.apache.flink.cdc.connectors.oracle.source.utils.OracleConnectionUtils.createOracleConnection(OracleConnectionUtils.java:61)
~[classes/:?]
at
org.apache.flink.cdc.connectors.oracle.source.OracleDialect.openJdbcConnection(OracleDialect.java:86)
~[classes/:?]
at
org.apache.flink.cdc.connectors.oracle.source.OracleDialect.discoverDataCollections(OracleDialect.java:103)
~[classes/:?]
at
org.apache.flink.cdc.connectors.oracle.source.OracleDialect.discoverDataCollectionSchemas(OracleDialect.java:113)
~[classes/:?]
at
org.apache.flink.cdc.connectors.oracle.source.OracleDialect.discoverDataCollectionSchemas(OracleDialect.java:52)
~[classes/:?]
at
org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceReader.discoverTableSchemasForStreamSplit(IncrementalSourceReader.java:336)
~[classes/:?]
... 20 more
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
