Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[FLINK-36345][feature][cdc-connector][oracle] Oracle cdc support partition table #3593

Open
wants to merge 11 commits into
base: master
Choose a base branch
from
Open

[FLINK-36345][feature][cdc-connector][oracle] Oracle cdc support partition table #3593

wants to merge 11 commits into from

Conversation

zhuxt2015
Copy link

Resolved the issue that Oracle CDC does not recognize Oracle partition tables

yuxiqian
yuxiqian reviewed Sep 4, 2024
View reviewed changes
Copy link
Contributor

@yuxiqian yuxiqian left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Thanks for @zhuxt2015's contribution! Would you mind adding a test case to verify this change?

@zhuxt2015 zhuxt2015 changed the title improve query oracle partition table [feature][cdc-connector][oracle] Oracle cdc support partition table Sep 21, 2024
@zhuxt2015 zhuxt2015 changed the title [feature][cdc-connector][oracle] Oracle cdc support partition table [FLINK-36345][feature][cdc-connector][oracle] Oracle cdc support partition table Sep 21, 2024
@zhuxt2015
Copy link
Author

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

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Reviewers

@yuxiqian yuxiqian yuxiqian left review comments

At least 1 approving review is required to merge this pull request.

Assignees
No one assigned
Labels
oracle-cdc-connector
Projects
None yet
Milestone
No milestone
Development

Successfully merging this pull request may close these issues.
4 participants
@zhuxt2015 @yuxiqian @PatrickRen @GOODBOY008